def Leader.elect

bend-kube-runtime@0.2.0.0 · src/leader.bend:168

import Base
import bend-kube-runtime@0.2.0.0/src/config.bend as K
import bend-kube-runtime@0.2.0.0/src/lease.bend as E

168# Runs work only while we hold the lease (client-go's RunOrDie).
169def Leader.elect(+cfg: K.Config, +o: LOpts, work: IO(Unit)) -> IO(Unit):
170  IO.bind(Unit, Unit, IO.spawn(Unit, Leader.on_signal(cfg, o)),
171    u => Leader.run(4294967295n, LTry{}, cfg, o, E.Obs.none(), False{}, 0, Some{work}))