This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
name := "postgresql-notifications" | |
version := "1.0" | |
scalaVersion := "2.11.7" | |
libraryDependencies ++= Seq("org.postgresql" % "postgresql" % "9.4-1200-jdbc41", | |
"org.scalikejdbc" %% "scalikejdbc" % "2.2.8", | |
"com.typesafe.akka" %% "akka-actor" % "2.4-SNAPSHOT", | |
"org.json4s" %% "json4s-native" % "3.2.10" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import akka.actor.{Props, ActorSystem, Actor} | |
import org.apache.commons.dbcp.{PoolingDataSource, DelegatingConnection} | |
import org.json4s.DefaultFormats | |
import org.postgresql.{PGNotification, PGConnection} | |
import scalikejdbc._ | |
import org.json4s.native.JsonMethods._ | |
import scala.concurrent.duration._ | |
/** |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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._ |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"flag" | |
"github.com/josdirksen/slackproxy/config" | |
"github.com/josdirksen/slackproxy/handlers" | |
"log" | |
"net/http" | |
) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package handlers | |
import ( | |
"io" | |
"net/http" | |
"fmt" | |
"github.com/fsouza/go-dockerclient" | |
"bytes" | |
"time" | |
"github.com/josdirksen/slackproxy/config" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package handlers | |
import ( | |
"io" | |
"net/http" | |
"fmt" | |
"github.com/fsouza/go-dockerclient" | |
"bytes" | |
"time" | |
"github.com/josdirksen/slackproxy/config" |