Module mz_compute::logging::compute

Logging dataflows for events generated by clusterd.

Structs

• ArrangementHeapDatum 🔒
• ArrangementSizeState 🔒
  State for tracking arrangement sizes.
• CollectionLogging
  Logging state maintained for a compute collection.
• DataflowGlobalDatum 🔒
• DemuxHandler 🔒
  Event handler of the demux operator.
• DemuxOutput 🔒
  Bundled output sessions used by the demux operator.
• DemuxState 🔒
  State maintained by the demux operator.
• ErrorCountDatum 🔒
• ExportDatum 🔒
• ExportState 🔒
  State tracked for each dataflow export.
• FrontierDatum 🔒
• HydrationTimeDatum 🔒
• ImportFrontierDatum 🔒
• LirMappingDatum 🔒
• LirMetadata
  Metadata for LIR operators.
• Peek
  A logged peek event.
• PeekDatum 🔒
• PeekDurationDatum 🔒

Enums

• ComputeEvent
  A logged compute event.
• PeekType

Traits

• LogDataflowErrors 🔒
  Extension trait to attach ComputeEvent::DataflowError logging operators to collections and batch streams.

Functions

• construct 🔒
  Constructs the logging dataflow for compute logs.
• make_string_datum 🔒
  Format the given value and pack it into a Datum::String.
• sum_batch_diffs 🔒
  Return the sum of all diffs within the given batch.

Type Aliases

• Logger
  Type alias for a logger of compute events.
• OutputSession 🔒
• Pusher 🔒
• Update 🔒