docker_client_interpreter.scala

def spotifyInterpreter(client: DockerClient): DockerOperation ~> Try = new (DockerOperation ~> Try) {
    override def apply[A](fa: DockerOperation[A]): Try[A] = fa match {
      case Pull(image: String) => Try {
        client.pull(image)
      }

      case Run(image: String, command@_*) => Try {
        val config = ContainerConfig.builder().cmd(command:_*).image(image).build()
        val container:ContainerCreation = client.createContainer(config)
        client.startContainer(container.id())
        container.id()
      }

      case Exec(containerId, command@_*) => Try {
        val params = Seq(ExecCreateParam.tty(true))
        val execCreation = client.execCreate(containerId, command.toArray[String], params:_*)
        val output: LogStream = client.execStart(execCreation.id)

        output.readFully()
      }

      case Kill(containerId) => Try {
        client.killContainer(containerId)
      }

      case Remove(containerId) => Try {
        client.removeContainer(containerId)
      }
    }
  }