Module logging 

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.

prometheus 🔒

Logging dataflow for Prometheus metrics gathered from the metrics registry.

reachability 🔒

Logging dataflows for events generated by timely dataflow.

resource_usage 🔒

Logging dataflow for the resource usage of the replica’s processes.

timely 🔒

Logging dataflows for events generated by timely dataflow.

Structs

BatchLogger 🔒

Logs events as a timely stream, with progress statements.

EventQueue 🔒

Parts to connect a logging dataflows the timely runtime.

LogCollection 🔒

Information about a collection exported from a logging dataflow.

PermutedRowPacker 🔒

Helper to pack collections of Datums into key and value row.

SharedLoggingState 🔒

State shared between different logging dataflow fragments.

Functions

consolidate_and_pack 🔒

A single-purpose function to consolidate and pack updates for log collection.

downgrade_to_interval_boundary 🔒

Downgrade cap to the next logging-interval boundary and schedule the operator’s next activation there. Returns the time the capability now holds.

emit_snapshot_diff 🔒

Emit the difference between two snapshots of a sampled source as updates at ts.

Type Aliases

OutputSession 🔒

A pusher for containers C. An output session for the specified container builder.

OutputSessionColumnar 🔒

An output session for columnar containers of updates D, using a column builder.

OutputSessionVec 🔒

An output session for vector-based containers of updates D, using a capacity container builder.

Update 🔒

An update of value D at a time and with a diff.