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 handleSettles an ended attempt, or appends an ask's op and answers it.
• def merged
• def empty.heap
• def empty.list
• def idleNo ticket is pending or running.
• def pending
• def flights.noneThe flights back, and whether none runs.
• type SwapKept: compaction failed before the rename, and the old journal stands.
• def swap.reopened
• def swap.renamedThe reopen fsyncs the directory, so the rename is durable before the next append.
• def swap.written
• def swap.opened
• def swapWrites snap as the only record of path.compact, fsyncs it, and renames it over path.
• def log.stop
• def compact.moved
• def compact.if
• def compact.done
• def compactWrites the state as one Snap record into a new journal, fsyncs it, and renames it over the old one.
• def tick.ran
• def tick.compacted
• def tick.due
• def tick.size
• def tick.grownCompacts once the journal grew past Config.compact octets since open or the last compaction.
• def tick.polled
• def tick.wait
• def tick.nextThe next message.
• def tick.gotHandles the message, then claims due tickets into free units with the claim fuel left.
• def tick.runHandles messages until no attempt runs and the inbox is empty.
• def tick.atFuel for each pending ticket, each attempt that may already run, and the last look at the inbox.
• def tickOne round: start an attempt for each due ticket the pool admits.
• def finished.of
• def finishedThe runner back, and whether no ticket is pending or running and no attempt runs.
• def drain.handled
• def drain.woke
• def drain.wait
• def drain.ticked
• def drain.if
• def drain.at
• def drain.end
• def drainTicks until no ticket is pending or running and no attempt runs.
• def orphans.next
• def orphansA running ticket at open lost its attempt in a crash: it is requeued at now, as a failed attempt.
• def close.answer
• def close.polled
• def close.drainAnswers each ask left in the closed inbox with a failure.
• def closeCloses the inbox and the journal.
• def open.done
• def open.got
• def replay.step
• def openOpens the runner at path: replays its journal into the state, then requeues each ticket that was running.
• def stateThe runner back, and a copy of its state.