bend-kube-runtime

Releases (2)

• 0.2.0.0 indexed
• 0.1.1.0 unindexed

Definitions (1,124)

src/kube.bend

• def Opts.with_leader
• def Opts.with_label
• def Kube.serve.go
• def Kube.serve
• def Kube.elect
• def Kube.start
• def Kube.poolUp to 8 idle keep-alive connections shared by every request.
• def Kube.configured
• def Kube.runRuns a controller for primary, owning owned, reconciling with rec.
• def Kube.start_allSeveral controllers in one process, sharing their watches (Manager): rec(i, obj, cfg) reconciles for the i-th controller of cs.
• def Kube.configured_all
• def Kube.run_all

src/leader.bend

• type LOpts
• def LOpts.default
• def LOpts.api
• def LOpts.name
• def LOpts.retry
• def LOpts.deadline
• def Leader.read.err
• def Leader.readThe Lease read: Some, None on 404, or the error.
• def Leader.decide
• type LEvWhat the loop just saw.
• def Leader.wrote
• def Leader.late
• def Leader.startedOn first acquiring: log and start the work.
• def Leader.lostA leader that cannot renew within the deadline stops at once (a candidate that fails just tries again).
• def Leader.runThe election loop.
• def Leader.release.mine
• def Leader.release.gotHands the lease back if it is ours.
• def Leader.release
• def Leader.on_signalOn SIGTERM or SIGINT: release the lease, then exit 0.
• def Leader.electRuns work only while we hold the lease (client-go's RunOrDie).

src/lease.bend

• type ObsWhat we last saw of the record, and when (our clock, in ms).
• type LeaseAct
• type Decision
• def Obs.none
• def Lease.spec
• def Lease.holder
• def Lease.renew_time
• def Lease.transitions
• def Lease.new_spec
• def Lease.freshA fresh Lease naming us.
• def Lease.observe.go
• def Lease.observeThe record seen now: the old observation if nothing changed, else a new one stamped now.
• def Lease.heldWhether another holder's lease is still live by our clock.
• def Lease.take.go
• def Lease.takeThe Lease rewritten to name us, keeping its metadata (resourceVersion).
• def Lease.decide.fin
• def Lease.decide.held
• def Lease.decide.got
• def Lease.decideOne round: the Lease read (None when absent), us, what we saw before, our clock in ms, the lease duration in seconds, and the time to stamp.
• def Lease.releaseThe Lease handed back: no holder, a one-second duration, so the next candidate takes it at once (client-go's ReleaseOnCancel).

src/log.bend

• def Log.line
• def Log.at
• def Log.info
• def Log.warn
• def Log.error
• def Log.kv

src/net.bend

• type Tls
• type Bytes
• def Res
• def Tls.dialA plain TCP connection: host may be a name (resolved, IPv4 or IPv6) or an IP literal; ms bounds the connect (0 for 30s).
• def Tls.secureHandshakes on a connection from Tls.dial and verifies the server as host (a name, or an IP literal), always: ca is a PEM bundle of trusted roots ("" for the system's), cert and key a PEM client certificate and key ("" for none), ms the handshake's deadline (0 for 30s).
• def Tls.sendSends text as UTF-8; ms bounds the whole send (0: no deadline).
• def Tls.send_bytesSends raw bytes (each 0..255); ms bounds the whole send (0: no deadline).
• def Tls.recvUp to max bytes (0: 16KiB); an empty list is the end of the stream.
• def Tls.close
• def Tls.fail
• type TunEvWhat the CONNECT exchange just saw.
• def TunEv.got
• def Tls.tunnelReads the proxy's answer to CONNECT; once it opens the tunnel, secures the connection end to end with the API server.
• def Tls.open.sent
• def Tls.open.proxied
• def Tls.open.direct
• def Tls.open.route
• def Tls.env.or
• def Tls.envThe first of two environment variables that is set and not empty, as Go reads HTTPS_PROXY then https_proxy.
• def Tls.openOpens a verified TLS connection to host:port (see Tls.secure), through the CONNECT tunnel of HTTPS_PROXY unless NO_PROXY or a loopback host says otherwise (proxy.bend).

src/proxy.bend

• type Proxy
• type Routeauth is the Basic credential (base64 of "user:password"), "" for none.
• def Ip4.octet.if
• def Ip4.octet.go
• def Ip4.octet
• def Ip4.join
• def Ip4.parse.go
• def Ip4.parse"10.1.2.3" as a number, if it is a dotted IPv4 address.
• def Ip4.is_loopback
• def Ip4.mask.goThe mask of a prefix length; None past 32.
• def Ip4.mask
• def Ip4.in
• def Ip4.mask.of
• def Ip4.cidr.go
• def Ip4.cidrWhether IPv4 host h lies in the "net/bits" block.
• type EntAn entry, split from its port ("" for any).
• def Ent.of.go
• def Ent.of
• def NoProxy.star
• def NoProxy.name.go
• def NoProxy.name
• def NoProxy.port_ok