scathon - Scala Marathon Client

This is a Scala Marathon Client. The aim is to provide a 100% coverage of the Marathon API (v0.16.0+) as a Scala SBT project.

Build status

Usage

Dependencies

libraryDependencies ++= Seq(
  "uk.co.appministry" %% "scathon-models" % "0.2.3",
  "uk.co.appministry" %% "scathon-client" % "0.2.3"
)

Scala 2.12

SCALA_VERSION=2.12.1
sbt ++$SCALA_VERSION -Dscala.version=$SCALA_VERSION clean test
sbt ++$SCALA_VERSION -Dscala.version=$SCALA_VERSION publishLocal
# and so on...

Creating the client

import uk.co.appministry.scathon.apiClient._
val client = new Client

Examples

The client comes with a rich unit tests suite. A lot of examples can be found inside those. A few quickstart examples below.

Loading applications:

client.getApps().onComplete {
  case Success(apps) => apps.foreach { app => /* ... */ }
  case Failure(ex) => println(s"There was an error while loading applications ${ex.getMessage}")
}

Loading an application by ID

client.getApp("/an/app/id").onComplete {
  case Success(app) => /* ... */
  case Failure(ex) => ex match {
    case _: NotFound => println(s"Application not found: ${ex.getMessage}")
    case _ => println(s"Error while loading an application: ${ex.getMessage}")
  }
}

Creating an application

import uk.co.appministry.scathon.models.mesos.UniqueConstraint
import uk.co.appministry.scathon.apiClient._
import uk.co.appministry.scathon.models._

val app = Application( id = "/app/test",
                       cmd = Some("/bin/sleep"),
                       args = Some(List("10")),
                       ports = Some(List(10000,10001,10002)),
                       instances = 2,
                       container = Some(Container(
                        docker = Some(ContainerDocker(
                          image = testAppContainerDockerImage,
                          network = DockerNetworkTypes.BRIDGE,
                          portMappings = Some(List(
                            ContainerPortMapping(10000, 0, None, PortMappingTypes.TCP),
                            ContainerPortMapping(10001, 0, None, PortMappingTypes.TCP),
                            ContainerPortMapping(10002, 0, None, PortMappingTypes.TCP)
                          ))
                        ))
                       )),
                       env = Map("ENV_VAR" -> "some-value"),
                       labels = Map( "consul.watch" -> "true",
                                     "consul.id" -> "test-app-0",
                                     "consul.name" -> "test-app",
                                     "consul.tags" -> "tag1,tag2" ),
                       acceptedResourceRoles = Some(List("*")),
                       constraints = Some(List(UniqueConstraint("hostname"))),
                       fetch = Some(List(FetchUri("http://www.apache.org/dyn/closer.lua/spark/spark-1.6.1/spark-1.6.1.tgz"))),
                       healthChecks = Some(List(HttpHealthCheck())) )
client.createApp(app).onComplete {
  case Success(createdApp) =>
    /* ... */
  case Failure(ex) => println(s"Error while creating an application: ${ex.getMessage}")
}

Subscribing to the event bus

val callbackUri = "http://localhost:9000/marathon/callbacks"
client.createEventSubscription(new URI(callbackUri)).onComplete {
  case Success(event) =>
    /* ... */
  case Failure(ex) => println(s"Failed to subscribe to the event bus: ${ex.getMessage}")
}

Code structure

This project comes in three modules:

scathon-client: Marathon client
scathon-models: models used by the client and...
scathon-test-server: test server used by the client for unit tests

Test server

This is a simplistic implementation of Marathon. It does not necessarily implement correct Marathon functionality but it simulates the responses Marathon would issue.
The project is very helpful is one's goal is to write a Marathon based application without having to run a complex infrastructure like mini-mesos.
To use the test server in one's unit tests:

libraryDependencies ++= Seq(
  "uk.co.appministry" %% "scathon-testserver" % "0.2.3" % "test"
)

In the unit tests:

import uk.co.appministry.scathon.apiClient._
import uk.co.appministry.scathon.testServer._

val server = new TestMarathon
server.start()
val client = new Client(port = server.port.get)
/* ... */

Configuring test server

testMarathon.bind-host: host to bind test server on, default localhost
testMarathon.bind-port: port to bind test server on, default random free port
testMarathon.executor-capacity: thread executor capacity, default 10
testMarathon.api-version: Marathon API version, default v2
testMarathon.for-unit-tests: used by the test server unit tests to verify correctness of the uris served, default false; usually, there is no need to play with this property

License

Author: Rad Gruchalski ([email protected])

This work will be available under Apache License, Version 2.0.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

radekg / scathon 0.2.3