def Manager.start

bend-kube-runtime@0.2.0.0 · src/runtime.bend:713

import Base
import bend-kube-runtime@0.2.0.0/src/json.bend as J
import bend-kube-runtime@0.2.0.0/src/config.bend as K
import bend-kube-runtime@0.2.0.0/src/queue.bend as Q

713# Runs every controller, sharing their watches. rec(i, obj, cfg) reconciles
714# obj for controller i.
715def Manager.start(~rec: U32 -> J.Json -> K.Config -> IO(Q.Action), +cfg: K.Config, +cs: List<&2, Ctrl>,
716  +status: Chan(SMsg)) -> IO(Unit):
717  IO.bind(List<&2, Chan(Msg)>, Unit, Manager.inboxes(cs),
718    +chs => IO.bind(Unit, Unit, Manager.watch(cfg, Plan.build(cs, chs, Nil{})),
719      u => Manager.loops(~rec, cfg, cs, chs, status, 0)))