drone dynamic

drone.scala

package drone

import fs2._
import java.time.Instant
import java.util.UUID

object Time {
  def local: Task[Instant] = Task.delay(Instant.now())
}

object Agent {
  sealed trait Work
}

trait Agent {
  def queue(work: Agent.Work): Task[UUID] = ???
  def completed: Stream[Task, Agent.Work] = ???
  def stop: Task[Unit] = ???
}

object Node {
  type State = List[Agent]
}

sealed trait Node {
  def stop: Task[Unit] = ???
}

sealed trait Container {
  def node: Task[Node] = ???
  def agent(node: Node): Task[Agent] = ???
}

sealed trait Job

object Dispatcher {
  case class State(node: Map[Node, Node.State])
}

final class Dispatcher(
  time: Task[Instant],
  container: Container,
  jobs: Stream[Task, Job]

) {
  def run(state: Dispatcher.State): Task[Unit] = {
    jobs.scan(Task.now(state)) { (current, job) =>
      //Logic using container, etc.. goes here returning a task
      current
    }.flatMap(Stream.eval).run
  }
}