Basic traefik integration

Author: Johannes Duesing

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Configuration.scala

@@ -9,6 +9,10 @@ class Configuration( ) {
   val bindHost: String = "0.0.0.0"
   val bindPort: Int = 8087
 
+  //Traefik data
+  val traefikBaseHost: String = "delphi.cs.upb.de"
+  val traefikDockerNetwork: String = "web"
+
 
   val recoveryFileName : String = "dump.temp"
 

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Docker/Container.scala

@@ -25,7 +25,14 @@ case class ContainerConfig(
                             Image: String,
                             Entrypoint: Option[Seq[String]] = None,
                             Cmd: Seq[String] = Seq.empty,
-                            Env: Seq[String] = Seq.empty)
+                            Env: Seq[String] = Seq.empty,
+                            Labels: Map[String, String] = Map.empty[String,String],
+                            ExposedPorts: Map[String, EmptyExposedPortConfig] = Map.empty,
+                            NetworkingConfig: NetworkConfig = NetworkConfig(Map.empty))
+
+case class NetworkConfig(EndpointsConfig: Map[String, EmptyEndpointConfig])
+case class EmptyEndpointConfig()
+case class EmptyExposedPortConfig()
 
 case class Networks(
                      IPAddress: String

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Docker/DockerActor.scala

@@ -36,27 +36,37 @@ class DockerActor(connection: DockerConnection) extends Actor with ActorLogging
      }
 
     case create(componentType, instanceId, containerName) =>
-      val containerConfig = ContainerConfig(Image = DockerImage.getImageName(componentType),
-        Env = Seq(s"INSTANCE_ID=$instanceId", s"DELPHI_IR_URI=${Registry.configuration.uriInLocalNetwork}",
-          s"DELPHI_JWT_SECRET=${Registry.configuration.jwtSecretKey}"))
+
+      val instancePort = componentType match {
+        case ComponentType.Crawler => Registry.configuration.defaultCrawlerPort
+        case ComponentType.WebApi => Registry.configuration.defaultWebApiPort
+        case ComponentType.WebApp => Registry.configuration.defaultWepAppPort
+        case t => throw new RuntimeException(s"Invalid component type $t, cannot deploy container.")
+      }
+
+      val networkConfig = NetworkConfig(Map(Registry.configuration.traefikDockerNetwork ->  EmptyEndpointConfig()))
+
+      val traefikHostUrl = componentType.toString.toLowerCase + instanceId.toString + "." + Registry.configuration.traefikBaseHost
+
+      val containerConfig = ContainerConfig(
+        Image = DockerImage.getImageName(componentType),
+        Env = Seq(
+          s"INSTANCE_ID=$instanceId",
+          s"DELPHI_IR_URI=${Registry.configuration.uriInLocalNetwork}",
+          s"DELPHI_JWT_SECRET=${Registry.configuration.jwtSecretKey}"
+        ),
+        Labels = Map("traefik.frontend.rule" -> s"Host:$traefikHostUrl"),
+        ExposedPorts = Map(s"$instancePort/tcp" -> EmptyExposedPortConfig()),
+        NetworkingConfig = networkConfig
+      )
 
       val createCommand = Try(Await.result(container.create(containerConfig, containerName), Duration.Inf))
       createCommand match {
         case Failure(ex) => sender ! Failure(ex)
         case Success(containerResult) =>
           Await.ready(container.start(containerResult.Id), Duration.Inf)
-          log.info(s"Docker Instance created and started")
-          val containerInfo = Await.result(container.get(containerResult.Id), Duration.Inf)
-
-          val instancePort = componentType match {
-            case ComponentType.Crawler => Registry.configuration.defaultCrawlerPort
-            case ComponentType.WebApi => Registry.configuration.defaultWebApiPort
-            case ComponentType.WebApp => Registry.configuration.defaultWepAppPort
-            case t => throw new RuntimeException(s"Invalid component type $t, cannot deploy container.")
-          }
-
-          log.info("ip address is " + containerInfo.IPAddress)
-          sender ! Success(containerResult.Id, containerInfo.IPAddress, instancePort)
+          log.info(s"Docker Instance created and started, host is $traefikHostUrl")
+          sender ! Success(containerResult.Id, traefikHostUrl, instancePort)
       }
 
     case stop(containerId) =>

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/Docker/JsonSupport.scala

@@ -69,7 +69,10 @@ trait JsonSupport extends SprayJsonSupport with DefaultJsonProtocol {
   }
   implicit val StatusFormat = jsonFormat6(ContainerStatus)
   implicit val ResponseFormat = jsonFormat2(CreateContainerResponse)
-  implicit val ConfigFormat = jsonFormat4(ContainerConfig)
+  implicit val ExposedPortConfigFormat = jsonFormat0(EmptyExposedPortConfig)
+  implicit val EndpointsConfigFormat = jsonFormat0(EmptyEndpointConfig)
+  implicit val NetworkConfigFormat = jsonFormat1(NetworkConfig)
+  implicit val ConfigFormat = jsonFormat7(ContainerConfig)
   implicit val NetworkFormat = jsonFormat1(Networks)
 }
 

src/main/scala/de/upb/cs/swt/delphi/instanceregistry/RequestHandler.scala

@@ -274,11 +274,10 @@ class RequestHandler(configuration: Configuration, instanceDao: InstanceDAO, con
             fireDockerOperationErrorEvent(None, s"Deploy failed with message: ${ex.getMessage}")
             Failure(new RuntimeException(s"Failed to deploy container, docker host not reachable (${ex.getMessage})."))
           case Success((dockerId, host, port)) =>
-            val normalizedHost = host.substring(1, host.length - 1)
-            log.info(s"Deployed new container with id $dockerId, host $normalizedHost and port $port.")
+            log.info(s"Deployed new container with id $dockerId, host $host and port $port.")
 
             val newInstance = Instance(Some(id),
-              normalizedHost,
+              host,
               port,
               name.getOrElse(s"Generic $componentType"),
               componentType,