Skip to content

Instantly share code, notes, and snippets.

View resume_jp.md

概要

求職者です。Scala開発者のポジションを探しています。

あなたの開発しているシステムがAkkaを使っているものである場合、私は貢献できるのではないかと思います。 (何度書き直してもこの一文が英語の下手な直訳調になる助けて。)

Akka/Scalaについてある程度詳しくて、特にAkka ActorとStreamsの内部動作について把握しており、過去Scala Kansai Summit 2018で発表したこんな動画も作っています。(リンクはこちら。下はサムネイル、クリックしても動画へは飛びません。)

2019-03-12_22h48_46

View resume.md

Overview

I’m looking for Scala developer roles, where I can remotely work from Japan. If your system is mainly based on Akka, written in Scala, I could be a candidate for your team. I am familiar with Akka/Scala especially about the core behavior of Akka Actor and Akka Streams. I could help in implementating Akka-based systems efficiently, avoiding common pitfalls to cause maintenance burden.

Unfortunately it's difficult for me to move outside Japan, but in terms of timezone/work hours I am fully flexible. I can work in hours your local team members are working.

View techempower.cf.yaml
AWSTemplateFormatVersion: "2010-09-09"
Resources:
# Define VPC and Subnet
VPC:
Type: AWS::EC2::VPC
Properties:
CidrBlock: 10.0.0.0/16
Tags:
- Key: Name
Value: techempower-vpc
View StreamError.scala
package example
import akka.actor.ActorSystem
import akka.stream.Attributes.LogLevels
import akka.stream.scaladsl.{Sink, Source}
import akka.stream.{ActorMaterializer, Attributes}
object Main {
def main(args: Array[String]): Unit = {
implicit val system = ActorSystem("exampleSystem")
View AkkaTypedPersistenceNoAdapter.scala
package example
import akka.persistence.typed.scaladsl.PersistentActor
import akka.persistence.typed.scaladsl.PersistentActor.{ Effect, CommandHandler }
import akka.actor.typed.{ Behavior, Terminated }
import akka.actor.typed.scaladsl.Actor
import akka.actor.ActorSystem
import com.typesafe.config.ConfigFactory
object AkkaTypedPersistenceNoAdapter {
View MySerializer.scala
package my.akka.typed
import java.io.{PrintWriter, StringWriter}
import akka.serialization.{SerializationExtension, SerializerWithStringManifest}
import akka.typed.scaladsl._
import akka.typed.scaladsl.adapter._
import com.typesafe.config.{Config, ConfigFactory}
object MySerializer {
View BackoffSuperVisorApp.scala
package my.akka
import akka.actor.{Actor, ActorRef, ActorSystem, PoisonPill, Props}
import akka.pattern.{Backoff, BackoffSupervisor, ask}
import scala.concurrent.Await
import scala.concurrent.duration._
class Child extends Actor {
@richardimaoka
richardimaoka / MyThrottle.scala
Last active Jun 24, 2017
Demonstrate Akka Stream's throttle
View MyThrottle.scala
package my.stream
import java.text.NumberFormat
import java.util.Locale
import akka.actor.ActorSystem
import akka.stream.scaladsl.{Keep, Sink}
import akka.stream.stage.{GraphStage, GraphStageLogic, InHandler, OutHandler}
import akka.stream.testkit.TestSubscriber
import akka.stream.testkit.scaladsl.TestSource
@richardimaoka
richardimaoka / MyActorIncarnation.scala
Last active Jun 18, 2017
Akka Actor's restart and stop followed by actor re-creation
View MyActorIncarnation.scala
//Place it under src/main/scala/my/actor
package my.actor
import akka.actor.SupervisorStrategy.{Restart, Stop}
import akka.actor.{Actor, ActorInitializationException, ActorKilledException, ActorRef, ActorSystem, DeathPactException, OneForOneStrategy, PoisonPill, Props, SupervisorStrategy}
import akka.pattern.ask
import akka.util.Timeout
View akka-exception-sample.scala
import akka.actor.{ActorSystem, Props, Actor}
import akka.actor.OneForOneStrategy
import akka.actor.SupervisorStrategy._
import scala.concurrent.duration._
class Supervisor extends Actor {
override val supervisorStrategy =
OneForOneStrategy(maxNrOfRetries = 10, withinTimeRange = 1 minute) {
case _: ArithmeticException => Resume