Kube.Kube.start: def of bend-kube-runtime@0.2.0.0 Import: import bend-kube-runtime@0.2.0.0/src/kube.bend as Kube Lines 55-65 of bend-kube-runtime@0.2.0.0/src/kube.bend: https://jend.leeeet.dev/read.txt?path=bend-kube-runtime@0.2.0.0/src/kube.bend&start_line=55&end_line=65 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/queue.bend as Q import bend-kube-runtime@0.2.0.0/src/runtime.bend as R import bend-kube-runtime@0.2.0.0/src/log.bend as L def Kube.start(~rec: J.Json -> K.Config -> IO(Q.Action), +cfg: K.Config, +primary: C.Api, owned: List<&2, C.Api>, o: Opts) -> IO(Unit): match o: case Opts{+m, +p, l, sel}: IO.bind(Chan(R.Msg), Unit, R.Controller.inbox(), +inbox => IO.bind(Chan(R.SMsg), Unit, R.Keeper.start(), +status => IO.bind(Unit, Unit, Kube.serve(p, status), u => IO.bind(Unit, Unit, L.Log.info("starting controller", [L.Log.kv("kind", R.Api.kind(primary)), L.Log.kv("server", K.Config.host(cfg))]), u2 => Kube.elect(cfg, l, R.Controller.start(~rec, cfg, primary, sel, owned, m, inbox, status)))))) Uses (21): https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.bind https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=List https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Unit https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/config.bend&name=Config https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/config.bend&name=Config.host https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/core.bend&name=Api https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/json.bend&name=Json https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/kube.bend&name=Kube.elect https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/kube.bend&name=Kube.serve https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/kube.bend&name=Opts https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/log.bend&name=Log.info https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/log.bend&name=Log.kv https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/queue.bend&name=Action https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Api.kind https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Controller.inbox https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Controller.start https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Keeper.start https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Msg https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=SMsg