Serve.Serve.probe: def of bend-kube-runtime@0.2.0.0 Import: import bend-kube-runtime@0.2.0.0/src/serve.bend as Serve Lines 68-76 of bend-kube-runtime@0.2.0.0/src/serve.bend: https://jend.leeeet.dev/read.txt?path=bend-kube-runtime@0.2.0.0/src/serve.bend&start_line=68&end_line=76 import Base import bend-kube-runtime@0.2.0.0/src/runtime.bend as R # Every controller's snapshot from the status keeper, which answers at once # (none on a standby replica). def Serve.probe(+status: Chan(R.SMsg)) -> IO(List<&2, R.Snap>): IO.bind(Chan(List<&2, R.Snap>), List<&2, R.Snap>, Chan.new(List<&2, R.Snap>, 1), +c => IO.bind(Result<&1, &1, R.SMsg, Unit>, List<&2, R.Snap>, Chan.send(R.SMsg, status, R.SGet{c}), u => IO.bind(Poll<&1, &1, Maybe<&1, List<&2, R.Snap>>, Unit>, List<&2, R.Snap>, Chan.try_recv(List<&2, R.Snap>, c, 500), m => IO.pure(List<&2, R.Snap>, Serve.probe.answer(m))))) Uses (15): https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.new https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.send https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.try_recv 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=IO.pure https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=List https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Maybe https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Poll https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result 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/runtime.bend&name=SMsg https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/runtime.bend&name=Snap https://jend.leeeet.dev/definition.txt?path=bend-kube-runtime@0.2.0.0/src/serve.bend&name=Serve.probe.answer