def Drv.pause.go

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

import Base
import bend-kube-runtime@0.2.0.0/src/log.bend as L

182def Drv.pause.go(+ms: U32, +fails: U32, path: String) -> IO(Unit):
183  IO.bind(Unit, Unit, L.Log.warn("list or watch failed; backing off",
184    [L.Log.kv("path", path), L.Log.kv("failures", U32.show(fails)),
185      L.Log.kv("delay_ms", U32.show(ms))]), u => IO.sleep(ms))