Set of utility classes to make integration testing with dockerised services in Scala easy.
You can read about reasoning behind it at Finely Distributed.
docker-it-scala utilises docker-java's way of configuration in performing initialisation with default settings.
import com.github.dockerjava.core.DockerClientConfig
trait DockerKit {
implicit val docker: Docker =
new Docker(DockerClientConfig.createDefaultConfigBuilder().build())
...
}
That makes it possible to configure it through enviroment variables
Docker Toolbox 1.9 (maybe also before, came some time in 2015) contains the docker-machine
command. With it, you get going simply by:
docker-machine start default
eval $(docker-machine env default)
export DOCKER_HOST=tcp://192.168.59.103:2376
export DOCKER_CERT_PATH=/Users/<username>/.boot2docker/certs/boot2docker-vm
export DOCKER_TLS_VERIFY=1
export DOCKER_HOST=tcp://127.0.0.1:2375
Since version 0.9.0-M2
you can use implementation with Spotify's docker-client in Docker for Mac setup as it works better with unix socket
import com.spotify.docker.client.DefaultDockerClient
import com.whisk.docker.impl.spotify.SpotifyDockerFactory
import com.whisk.docker.{DockerFactory, DockerKit}
trait MyDockerKit extends DockerKit {
override implicit val dockerFactory: DockerFactory =
new SpotifyDockerFactory(DefaultDockerClient.fromEnv().build())
}
with
export DOCKER_HOST=unix:///var/run/docker.sock
Artifacts are available for Scala 2.10 and 2.11
Include a dependency on one of the testkits of your choice to get started.
libraryDependencies += "com.whisk" %% "docker-testkit-specs2" % "0.8.3" % "test"
libraryDependencies += "com.whisk" %% "docker-testkit-scalatest" % "0.8.3" % "test"
If you want to configure via typesafe config (only for Scala 2.11), also include
libraryDependencies += "com.whisk" %% "docker-testkit-config" % "0.8.3" % "test"
libraryDependencies ++= Seq(
"com.whisk" %% "docker-testkit-scalatest" % "0.9.0-M3" % "test",
"com.whisk" %% "docker-testkit-impl-spotify" % "0.9.0-M3" % "test")
There are two ways to define a docker container.
Code based definitions and via typesafe-config
.
trait DockerMongodbService extends DockerKit {
val DefaultMongodbPort = 27017
val mongodbContainer = DockerContainer("mongo:3.0.6")
.withPorts(DefaultMongodbPort -> None)
.withReadyChecker(DockerReadyChecker.LogLineContains("waiting for connections on port"))
.withCommand("mongod", "--nojournal", "--smallfiles", "--syncdelay", "0")
abstract override def dockerContainers: List[DockerContainer] = mongodbContainer :: super.dockerContainers
}
docker-testkit-config
enables you to use a typesafe config to
define your docker containers. Just put an application.conf
file in
your classpath.
The container definitions are nested in the structure of name docker
docker {
...
...
}
See application.conf for more examples.
Usage in code
trait DockerMongodbService extends DockerKitConfig {
val mongodbContainer = configureDockerContainer("docker.mongodb")
abstract override def dockerContainers: List[DockerContainer] =
mongodbContainer :: super.dockerContainers
}
- Cassandra =>
docker.cassandra
- Elasticsearch =>
docker.elasticsearch
- Kafka =>
docker.kafka
- Mongodb =>
docker.mongo
- Neo4j =>
docker.neo4j
- Postgres =>
docker.postgres
image-name
required (String)environmental-variables
optional (Array of Strings)ready-checker
optional structurelog-line
optional (String)http-response-code
port
required (Int)path
optional (String - defaults to/
)within
optional (Int)looped
optional structureattempts
required (Int)delay
required (Int)
port-maps
optional structure (list of structures)SOME_MAPPING_NAME
internal
required (Int)external
optional (Int)
volume-maps
optional structure (list of structures)container
required (String)host
required (String)rw
optional (Boolean - default:false)
There are two testkits available -- one for scalatest
and one for
specs2
.
Both set up the necessary docker containers and check that they are ready BEFORE any test is run, and doesn't close the container until ALL the tests are run.
class MyMongoSpec extends FlatSpec with Matchers with DockerMongodbService {
...
}
class AllAtOnceSpec extends FlatSpec with Matchers with BeforeAndAfterAll with GivenWhenThen with ScalaFutures
with DockerElasticsearchService with DockerCassandraService with DockerNeo4jService with DockerMongodbService {
implicit val pc = PatienceConfig(Span(20, Seconds), Span(1, Second))
"all containers" should "be ready at the same time" in {
dockerContainers.map(_.image).foreach(println)
dockerContainers.forall(_.isReady().futureValue) shouldBe true
}
}
Examples can be found in the specs2 module's tests