Skip to main content

Module correction

Module correction 

Source
Expand description

The Correction data structure used by persist_sink::write_batches to stash updates before they are written into batches.

Structs§

ChannelLogging
Channel-based logging for corrections on a Tokio task. Send-safe.
CorrectionV1
A collection holding persist_sink updates.

Enums§

Correction
A data structure suitable for storing updates in a self-correcting persist sink.
LoggingEvent
A logging event sent from the Tokio task back to the Timely thread.