Expand description
The Correction data structure used by persist_sink::write_batches to stash updates before
they are written into batches.
Structs§
- Channel
Logging 🔒 - Channel-based logging for corrections on a Tokio task.
Send-safe. - Consolidating
Vec 🔒 - A vector that consolidates its contents.
- Correction
Logger 🔒 - State for correction buffer logging on the Timely thread.
- Correction
V1 🔒 - A collection holding
persist_sinkupdates. - Length
AndCapacity 🔒 - Helper type for convenient tracking of length and capacity together.
- Size
Metrics 🔒 - Helper type for convenient tracking of various size metrics together.
Enums§
- Correction 🔒
- A data structure suitable for storing updates in a self-correcting persist sink.
- Logging
Event 🔒 - A logging event sent from the Tokio task back to the Timely thread.