Module mz_compute::logging::timely

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 🔒
• ScheduleHistogramDatum 🔒

Functions

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

Type Aliases

• OutputSession 🔒
• Pusher 🔒