Skip to content

Instantly share code, notes, and snippets.

View dsugden's full-sized avatar

Dave Sugden dsugden

  • Shopify
  • Gatineau
View GitHub Profile
BundleKeys.endpoints := Map("akka-remote" -> Endpoint("tcp", 8084, Set.empty))
BundleKeys.system := "SomeAkkaClusterSystem"
BundleKeys.startCommand += "-Dhttp.address=$SINGLEMICRO_BIND_IP -Dhttp.port=$SINGLEMICRO_BIND_PORT"
sys.env.get("SINGLEMICRO_BIND_IP")
singlemicro {
ip = "127.0.0.1"
ip = ${?SINGLEMICRO_BIND_IP}
port = 8096
port = ${?SINGLEMICRO_BIND_PORT}
}
BundleKeys.endpoints := Map("singlemicro" -> Endpoint("http", 0, Set(URI("http:/singlemicroservice"))))
akka.remote {
netty.tcp {
hostname = "127.0.0.1"
port = 8089
}
}
version = "1.0.0"
name = "singlemicro"
system = "singlemicro-1.0.0"
nrOfCpus = 1.0
memory = 67108864
diskSpace = 5000000
roles = ["backend"]
components = {
"singlemicro-1.0.0" = {
description = "singlemicro"
enablePlugins(JavaAppPackaging,ConductRPlugin)
BundleKeys.nrOfCpus := 1.0
BundleKeys.memory := 10.MiB
BundleKeys.diskSpace := 5.MB
BundleKeys.endpoints := Map("singlemicro" -> Endpoint("http",0,services = Set(URI("http:/singlemicro"))))
@dsugden
dsugden / upickleakkahttp.scala
Last active August 29, 2015 14:12
upickle akka-http
import akka.http.marshalling._
import akka.http.model._
import akka.http.unmarshalling.{FromResponseUnmarshaller, FromRequestUnmarshaller, Unmarshaller}
import akka.stream.FlowMaterializer
import upickle.{Writer, Reader}
import scala.concurrent.duration._
import scala.concurrent.{ExecutionContext, Future}
import scala.language.implicitConversions