richardimaoka

概要

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

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

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

richardimaoka

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.

richardimaoka

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

richardimaoka

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")

richardimaoka

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 {

richardimaoka

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 {

richardimaoka

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

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

//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

richardimaoka

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