Skip to content

Instantly share code, notes, and snippets.

package handlers
import (
"net/http"
"fmt"
"bytes"
"github.com/shirou/gopsutil/mem"
"github.com/shirou/gopsutil/host"
"io"
)
package handlers
import (
"io"
"net/http"
"fmt"
"github.com/fsouza/go-dockerclient"
"bytes"
"time"
"github.com/josdirksen/slackproxy/config"
FROM golang:latest
COPY src/ /go/src/
COPY resources/config.json /
EXPOSE 9000
# If external packages are needed, install them manually. Not needed if installed in the GOPATH
RUN go get github.com/fsouza/go-dockerclient && go install github.com/fsouza/go-dockerclient
RUN go get github.com/shirou/gopsutil && go install github.com/shirou/gopsutil
WORKDIR src
package handlers
import (
"io"
"net/http"
"fmt"
"github.com/fsouza/go-dockerclient"
"bytes"
"time"
"github.com/josdirksen/slackproxy/config"
package main
import (
"flag"
"github.com/josdirksen/slackproxy/config"
"github.com/josdirksen/slackproxy/handlers"
"log"
"net/http"
)
import AkkaTypedReceptionist.FirstService.{FirstServiceMsg1, FirstServiceMsg}
import AkkaTypedReceptionist.SecondService.{SecondServiceMsg1, SecondServiceMsg}
import AkkaTypedReceptionist.SenderService.{sendMessage, registerAddresses, SenderMsg}
import akka.typed.{ActorSystem, Props, ActorRef, PreStart}
import akka.typed.ScalaDSL._
import akka.typed.patterns.Receptionist
import akka.typed.patterns.Receptionist._
object AkkaTypedReceptionist extends App {
import java.io.{File, FileInputStream}
import java.security.KeyStore
import com.jayway.restassured.RestAssured
import com.jayway.restassured.config.SSLConfig
import com.jayway.restassured.http.ContentType
import com.jayway.restassured.response.Response
import org.apache.http.conn.ssl.{SSLConnectionSocketFactory, SSLSocketFactory}
import org.scalatest._
import akka.typed.patterns.Receiver._
import akka.typed._
import akka.typed.patterns.Receiver
import akka.typed.ScalaDSL._
import scala.concurrent.duration._
object AkkaTypedReceiver extends App {
sealed trait HelloMsg
final case class HelloCountry(country: String) extends HelloMsg
import akka.typed._
import akka.typed.ScalaDSL._
import akka.typed.AskPattern._
import akka.util.Timeout
import scala.concurrent.Future
import scala.concurrent.duration._
import scala.concurrent.Await
object AkkaTyped extends App {
name := "akka-http-websockets"
version := "1.0"
scalaVersion := "2.11.6"
libraryDependencies ++= Seq(
"com.typesafe.akka" %% "akka-stream-experimental" % "1.0-RC2",
"com.typesafe.akka" %% "akka-http-core-experimental" % "1.0-RC2",
"com.typesafe.play" %% "play-json" % "2.3.4"