Module timely

Source
Expand description

Logging dataflows for events generated by timely dataflow.

Structs§

ChannelDatum 🔒
DemuxHandler 🔒
Event handler of the demux operator.
DemuxOutput 🔒
Bundled output buffers used by the demux operator.
DemuxState 🔒
State maintained by the demux operator.
MessageCount 🔒
Organize message counts into number of batches and records.
MessageDatum 🔒
Park 🔒
ParkDatum 🔒
Return 🔒
The return type of construct.
ScheduleHistogramDatum 🔒

Functions§

construct 🔒
Constructs the logging dataflow fragment for timely logs.
grow_vec 🔒
Grow the given vector so it fits the given index.

Type Aliases§

OutputSession 🔒
Pusher 🔒