Expand description
Logging dataflows for events generated by various subsystems.
Re-exports§
pub use crate::logging::initialize::initialize;
Modules§
- compute
- Logging dataflows for events generated by clusterd.
- differential 🔒
- Logging dataflows for events generated by differential dataflow.
- initialize 🔒
- Initialization of logging dataflows.
- reachability 🔒
- Logging dataflows for events generated by timely dataflow.
- timely 🔒
- Logging dataflows for events generated by timely dataflow.
Structs§
- Batch
Logger 🔒 - Logs events as a timely stream, with progress statements.
- Event
Queue 🔒 - Parts to connect a logging dataflows the timely runtime.
- LogCollection 🔒
- Information about a collection exported from a logging dataflow.
- Permuted
RowPacker 🔒 - Helper to pack collections of
Datum
s into key and value row. - Shared
Logging 🔒State - State shared between different logging dataflow fragments.
Functions§
- consolidate_
and_ 🔒pack - A single-purpose function to consolidate and pack updates for log collection.
Type Aliases§
- Output
Session 🔒 - An output session for the specified container builder.
- Output
Session 🔒Columnar - An output session for columnar containers of updates
D
, using a column builder. - Output
Session 🔒Vec - An output session for vector-based containers of updates
D
, using a capacity container builder. - Pusher 🔒
- A pusher for containers
C
. - Update 🔒
- An update of value
D
at a time and with a diff.