bend-kube-runtime

Search uses release 0.2.0.0 · 1,124 definitions

Releases (2)

def NoProxy.ent
def NoProxy.hit.go
def NoProxy.hit
def NoProxy.any
def NoProxy.commas
def NoProxy.bypassWhether NO_PROXY (no) sends host:port around the proxy.
def Pct.hex.go
def Pct.hexA hex digit's value, 16 for any other character.
def Pct.esc.if
def Pct.esc
def Pct.decodeThe bytes of a percent-encoded URL part ("%40" is '@'); a '%' that starts no escape stays as it is.
def Proxy.parse.fin
def Proxy.parse.hp
def Proxy.parse.atThe authority's parts split at '@', last first: the host, then the user info (which may itself hold an '@').
def Proxy.parse.auth
def Proxy.parse.go
def Proxy.parse"http://user:pass@host:port", or "host:port" (http:// is assumed, as Go does).
def Proxy.route.url
def Proxy.route.no
def Proxy.route.local
def Proxy.is_local
def Proxy.routeHow to reach host:port, given HTTPS_PROXY (url) and NO_PROXY (no): localhost and loopback addresses never use a proxy (as in Go), nor do hosts NO_PROXY lists, nor anything when no proxy is set.
def Proxy.target.go
def Proxy.target
def Proxy.auth_line.go
def Proxy.connectThe request that opens a tunnel to host:port.
type Tunnel
def Tunnel.init
def Tunnel.is_end
def Tunnel.line.if
def Tunnel.lineThe bytes before the first CR.
def Tunnel.verdict.go
def Tunnel.verdict
def Tunnel.done
def Tunnel.push
def Tunnel.cap.go
def Tunnel.cap
def Tunnel.more
def Tunnel.feedThe tunnel after the next bytes of the answer; no bytes is the end.

type Action
type Queue
type TimerA timer for the driver to start: wake key after ms with this generation.
def Queue.new
def Mp.has.fin
def Mp.has
def Mp.get.fin
def Mp.get
def Mp.on
def Mp.off
def Mp.bump
def Queue.add.go
def Queue.addQueues key unless it waits already; a running key is marked dirty instead.
def Queue.add_all
def Queue.pop.flip
def Queue.pop.go
def Queue.popThe next waiting key, if a worker slot is free: it leaves the queue and starts running.
def Queue.pop_all.q
def Queue.pop_all.acc
def Queue.pop_allEvery key that may start now, in queue order (fuel bounds the count).
def Queue.backoff.go
def Queue.backoffThe delay after fails failures: 5ms doubling, at most 1000s.
def Queue.done.fails
def Queue.done.dirty
def Queue.armStarts a timer for key, staling any earlier one.
def Queue.done.timer
def Queue.done.run
def Queue.done.go
def Queue.running
def Queue.doneA run of key ended with an action.
def Queue.wake.go
def Queue.wakeA timer woke: the key is queued if the timer is still current.
def Queue.waiting
def Queue.nrun
def Queue.forget.go
def Queue.forgetDrops what the queue remembers of a key whose object is gone (its timer generation and failures, as client-go's Forget does), so memory follows the live objects.
def Queue.forget_all

type Msg
type SnapThe controller's state as the health server reports it.
type SMsgThe status keeper's inbox: a controller's latest snapshot (by its index), or a query for all of them (none until a controller runs: a standby replica).
type StatsCounters since start.
type SubWho a watcher feeds: each subscriber's inbox, and the source number the outputs carry there (0 for a controller's primary, 1..
type WCtx
type DEvWhat the driver just saw.
def DEv.recv
def Drv.inputsThe inputs a run of watch lines makes; blank lines are skipped.
def Drv.inputs.parThe same, with the lines decoded and parsed in parallel: each line is its own JSON document, so the halves split (to depth levels, up to 2^depth tasks) run as Bend parallel calls, on every core.
type DigAfter a recv: the stream's state, and the step its whole lines make.
def Drv.status
def Drv.ended
def Drv.digest.end.go
def Drv.digest.endA stream that ended cleanly is a watch timeout: the watcher resumes.
def Drv.digest.fin
def Drv.digest.lines
def Drv.digest.ok
def Drv.digest.go
def Drv.digest
def Drv.send
def Drv.send_allHands the outputs to every subscriber (a shared watch fans out).
def Drv.jitter
def Drv.pause.go