def Ctl.loop

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

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

607def Ctl.loop(~rec: U32 -> J.Json -> K.Config -> IO(Q.Action), +cfg: K.Config, +primary: C.Api, +max: U32,
608  +chan: Chan(Msg), +status: Chan(SMsg), +idx: U32) -> IO(Unit):
609  Ctl.run(~rec, 4294967295n,
610    CDisp{(CState{S.Store.new(), Q.Queue.new(max), Stats{0, 0, 0}}, Nil{})},
611    CState{S.Store.new(), Q.Queue.new(max), Stats{0, 0, 0}},
612    CCtx{cfg, Api.kind(primary), chan, status, idx})