Skip to main content

Module processor

Module processor 

Source
Expand description

The ingestion driver: applies one log entry atomically, and exposes the stored log back as a Replica.

A Processor pairs a Reducer with an HlcService clock and a LogTracker: ingesting an entry advances the clock, records it via the tracker, and applies the reducer’s writes in one all-or-nothing batch. It always implements HasCursors and LogProcessor; when its tracker keeps full history (HistoryTracker) it also implements LogSource, and so is a Replica.

Structs§

Processor
Drives a Reducer over a Db: applies local writes (exec) and ingests remote log entries, advancing the HLC and per-peer cursors and emitting change events through its EventHandler. This is the concrete engine behind the Store/SqlStore surface (open one with open); it also implements the sync traits.

Enums§

ProcessorError
A failure while ingesting an entry, tagged by the stage that produced it.

Type Aliases§

BoxError
A reducer error erased to a trait object — the uniform reducer-error type the Store surface exposes across reducers.