def Kube.configured

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

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

71def Kube.configured(~rec: J.Json -> K.Config -> IO(Q.Action), c: Result<&2, &2, String, K.Config>,
72  primary: C.Api, owned: List<&2, C.Api>, o: Opts) -> IO(Unit):
73  match c:
74    case Done{cfg}:
75      IO.bind(Chan(Socket), Unit, Kube.pool(),
76        p => Kube.start(~rec, K.Config.with_pool(cfg, p), primary, owned, o))
77    case Fail{e}:
78      IO.die(Unit, 1, "bend-kube: no config: " ++ e)