bend-kube-runtime

Search uses release 0.2.0.0 · 1,124 definitions

Releases (2)

0.2.0.0 indexed
0.1.1.0 unindexed

Definitions (1,124)

src/runtime.bend

def Drv.pauseSleeps the watcher's backoff, with up to 50% jitter, when asked to.
def Drv.note_listA list from its first page (startup, or a relist after 410 Gone).
def Drv.close
def WState.fails
def WCtx.list_req
def WCtx.watch_req
def WCtx.path
def WCtx.cfg
def WCtx.subs
def Drv.runThe watcher's loop: list, then watch and stream, reconnecting and relisting as the state machine says, until the fuel or the channel ends.
type CState
type CCtx
type JobA reconcile to start: the key and the object the store holds for it.
type CEvWhat the controller loop just saw.
def Ctl.self_keysThe keys a primary watcher's outputs trigger: every object it applies.
def Ctl.gone_keysThe keys of objects a primary watcher saw deleted.
def Ctl.ref_keys
def Ctl.out_obj
def Ctl.owner_keys.put
def Ctl.owner_keysThe keys an owned watcher's outputs trigger: the owners of the kind every changed object names (kube-runtime's Controller::owns), deletions included.
def Stats.count
def Stats.events
def Stats.done
def Ctl.on_outs
def Ctl.on_done
def Ctl.on_done.st
def Ctl.on_wake
def Ctl.on_msgA message's effect on the state, and the timers it arms.
def Ctl.dispatch.drop
def Ctl.dispatch.put
def Ctl.dispatch.acc
def Ctl.dispatch.go
def Ctl.dispatch.wrap
def Ctl.dispatch.fin
def Ctl.dispatch.ready
def Ctl.dispatchThe reconciles to start now: none until the store has its first list.
def Ctl.snap
def Ctl.timers
def CCtx.chan
def CCtx.cfg
def CCtx.status
def CCtx.idx
def CCtx.kind
def Ctl.spawnStarts a reconcile per job; each answers MDone on the channel.
def Ctl.runThe controller loop: a message in, the state stepped, timers armed, reconciles started, the next message awaited.
def Ctl.watch.subs
def Ctl.watch
def Ctl.watch_all
def Api.kind
def Keeper.all.put
def Keeper.all.go
def Keeper.all
def Keeper.runThe status keeper: holds each controller's latest snapshot and answers queries at once.
def Keeper.startStarts a status keeper; answers its inbox.
def Ctl.loop
def Controller.startRuns a controller (kube-runtime's Controller::new(..).owns(..).run(..)): primary is watched (only objects matching the label selector, "" for all) and reconciled, each of owned is watched and mapped to its owners of primary's kind; at most max reconciles run at once.
def Controller.inbox
type CtrlA controller of a manager: its primary watch (with a label selector), the kinds it owns, and how many reconciles it runs at once.
type Watch
def Watch.key
def Plan.hit
def Plan.addAdds a subscription: to the watch of the same key, or as a new watch.
def Plan.sub
def Plan.owned
def Plan.buildEvery watch the controllers need, each once, with all its subscribers.
def Manager.inboxes
def Manager.watch
def Manager.loops
def Manager.startRuns every controller, sharing their watches.

src/serve.bend

def Serve.Res
def Serve.size
def Serve.reason.go
def Serve.reason
def Serve.reply
def Serve.first_line.go
def Serve.first_line
def Serve.path.go
def Serve.pathThe request line's path.
def Serve.probe.answer
def Serve.probeEvery controller's snapshot from the status keeper, which answers at once (none on a standby replica).
def Serve.all_ready
def Serve.ready.go
def Serve.readyReady when every controller's store has listed; a standby is ready.
def Serve.bool
def Serve.head
def Serve.snap.name
def Serve.snap.pick.go
def Serve.snap.pick
def Serve.snap.fieldThe field-th number of a snapshot (0 ready, 1 reconciles, 2 errors, 3 events, 4 running, 5 objects).
def Serve.samplesOne sample per controller, labeled with its kind.
def Serve.family
def Serve.textThe Prometheus text format: one sample per controller; a standby replica reports only that it leads nothing.
def Serve.metrics
def Serve.routeThe answer to a request.
def Serve.answer.done
def Serve.answer
def Serve.handle.got
def Serve.handle
def Serve.accepted
type AEv