lregnier

Warehouse Example

Table of Contents

• Setup Schema
• Operations
  • Warehouses
    • Create Warehouse
    • Read Warehouse
• Read All Warehouses

lregnier

import java.util.Date

import com.auth0.jwt.algorithms.Algorithm
import com.auth0.jwt.interfaces.DecodedJWT
import com.auth0.jwt.{JWT => Auth0JWT}
import com.typesafe.config.Config

import scala.util.Try

object JWT {

lregnier

import akka.actor.{Actor, ActorSystem, Props}
import akka.testkit.{ImplicitSender, TestActorRef, TestKit}
import org.scalatest.WordSpecLike
import scala.concurrent.duration._

class SynchronousVsAsynchronousSpec
    extends TestKit(ActorSystem("synchronous-vs-asynchronous-spec"))
    with ImplicitSender
    with WordSpecLike {

lregnier

import akka.actor.{Actor, ActorLogging, ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider}
import akka.pattern.pipe
import com.typesafe.config.Config

import scala.concurrent.Future
import scala.concurrent.duration.Duration

object ActorCaching {
  case class SaveToCache(msg: Any, response: Any)
  case class RemoveFromCache(msg: Any)

lregnier

Keybase proof

I hereby claim:

• I am lregnier on github.
• I am lregnier (https://keybase.io/lregnier) on keybase.
• I have a public key ASB1FV_t35RpiUaURaAugxtwNPDaSQZlhBUUjNFT4J1x5Ao

To claim this, I am signing this object:

lregnier

Scala with Style (by Martin Odersky)

This is a summary of the guidelines presented by Martin Odersky during his talk Scala with Style.

Table of Contents

• Guidelines
  • 1. Keep it simple
  • 2. Don't pack too much in one expression
  • 3. Prefer Functional
• 4. But don't diabolize local state

lregnier

import akka.actor.{Actor, ActorIdentity, ActorLogging, ActorRef, FSM, Identify, Props, Stash, Terminated}

import scala.concurrent.duration.{Duration, _}

object RemoteActorProxy {

  sealed trait State
  case object Identifying extends State
  case object Active extends State

lregnier

import akka.actor.{Actor, ActorLogging, ActorSystem, Props}
import akka.event.Logging
import akka.routing.RoundRobinPool

import scala.concurrent.Await
import scala.concurrent.duration._

object RouteeActor {
  def props(): Props = Props[RouteeActor]
}