bend-kit-runner

Releases (18)

• 0.13.0.1 indexed
• 0.13.0.0 unindexed
• 0.12.0.1 unindexed
• 0.12.0.0 unindexed
• 0.11.0.1 unindexed
• 0.11.0.0 unindexed
• 0.10.0.1 unindexed
• 0.10.0.0 unindexed
• 0.9.0.0 unindexed
• 0.8.1.0 unindexed
• 0.8.0.0 unindexed
• 0.7.0.0 unindexed
• 0.6.0.0 unindexed
• 0.5.0.0 unindexed
• 0.4.0.0 unindexed
• 0.3.0.0 unindexed
• 0.2.0.0 unindexed
• 0.1.0.0 unindexed

Definitions (251)

runner.bend

• def rd.u64.of
• def rd.u64
• def rd.cut.got
• def rd.cut.if
• def rd.cut.at
• def rd.cutThe next n octets.
• def rd.flag.of
• def rd.flagA u32 flag: 1 is True, 0 is False, and any other value fails.
• def rd.payload
• def rd.ticket
• def rd.heapEach rd.* tree reader takes the flag already read.
• def rd.run
• def rd.tries
• def rd.why
• def rd.entries
• def rd.gravesA trie node whose kind is already read: nil is kind 0, leaf kind 1, and branch kind 2.
• def rd.wfThe trie, when it is well formed as the never-selected laws assume.
• def rd.charsEach rd.* sequence reader takes the count or flag already read.
• def rd.key
• def rd.nats
• def rd.closed
• def rd.brk.of
• def rd.brk
• def rd.break
• def rd.brks
• def rd.state
• def rd.doneThe value read, when the reader ended at len, the record's end.
• def decode.abandonThe Abandon of ticket a at e whose why.code is c, or None for any other code.
• def decode.small
• def decode.long
• def decode.payload
• def decode.c.if
• def decode.cAn Abandon is 28 octets; every other op without a payload is 20.
• def decode.kind
• def decode.a
• def decode.tag.if
• def decode.tag
• def decode.len
• def decodeThe op of a record, or None when it is not one that encode writes.
• def decode.snapThe state of a Snap record whose tag is already checked.
• def decode.snapped
• def decode.did
• def decode.rec.if
• def decode.rec.tag
• def decode.recThe Rec of a journal record, or None when it is neither a Snap nor an op that encode.rec writes.
• type Configpolicy: retry's policy for each ticket.
• type LogThe journal, its path, its file cap, and its length at open or at the last compaction.
• type FlightAn attempt that runs: its unit of the pool, the budget that admit left, and its target.
• def Out
• type MsgA message to the fiber that owns the runner.
• type RunnerAn open runner.
• def ClaimedThe runner, the claim fuel left, and the first error.
• def Ran
• def clockWall-clock ms since the Unix epoch.
• def first
• def log.appended
• def log.append
• def log.close
• def log.ofThe journal reads with limit as its record cap, so that a snapshot fits; appends keep max.
• def commit.done
• def commitAppends op, and applies it once the append is durable.
• def enqueue.done
• def enqueueAdds a job that is due at deadline (wall-clock ms) and answers its ticket id once the record is durable.
• def cancelCancels ticket id.
• def reviveMakes dead ticket id pending again at deadline (wall-clock ms), with its payload and a new retry budget.
• def purgeDrops, as one record, the dead tickets that retry gave up on before `before` (wall-clock ms).
• def purge.allDrops every dead ticket, as one record.
• def inboxThe runner back, and its inbox.
• def ask.answer
• def ask.sent
• def askSends m, built with a new reply channel, on the inbox and waits for the reply.
• def ask.enqueueFrom another fiber: adds a job due at deadline, and answers its ticket id once the record is durable.
• def ask.cancelFrom another fiber: cancels ticket id, as cancel does.
• def release.gotA grant of this runner's pool always fits it, so Kept does not happen.
• def release
• def claim.held
• def claim.tag
• def trip.if
• def tripAppends a Break when the target's breaker left old, so that a reopen restores it.
• def claim.go
• def claim.tripped
• def claim.gateA change to the breaker is durable before the attempt starts.
• def claim.admitThe selected ticket asks its target's breaker and its own budget for an attempt.
• def claim.selected
• def claim.pick
• def claimStarts an attempt for each due ticket while the pool has a free unit; each attempt sends its outcome on the inbox.
• def settle.done
• def settle.br
• def settle.opTells the target's breaker, appends the outcome's op, and returns the attempt's unit to the pool.
• def random
• def take.keep
• def take.at
• def takeThe flight of ticket id, and the other flights.
• def settle.flight
• def settle.take
• def settleSettles the flight of ticket id with outcome o.
• def asked.failedSends the failure to the asker, and keeps it as the round's error.
• def asked.fail
• def added
• def dropped