ReplayGate

How a node's state reads that replay the log run: KernelStateReads replays an aggregate's latest state without a snapshot, a state at a version or a time, and a trace inside replay, which the host runs under the query bulkhead of the aggregate's log store, so that point reads cannot take every connection the store's appends draw from. Background replays (the access walk's) also ask whether that store's writes are pressed (pressed), and give way while they are.

Types

Link copied to clipboard

Functions

Link copied to clipboard
open fun pressed(type: AggregateType): Boolean

Whether the writes of type's log store pressed in their last period, as the store's adaptive query bound read them (callers waiting for a connection, or appends slower than their baseline); false when nothing reads them.

Link copied to clipboard
abstract suspend fun <T> replay(ref: AggregateRef, read: suspend () -> T): T

Runs read, the replay of ref's log, or throws to refuse it (the bulkhead's wow.query.busy).