Module mz_compute::logging::compute

Logging dataflows for events generated by clusterd.

Structs

• ArrangementHeapDatum 🔒
• ArrangementSizeState 🔒
  State for tracking arrangement sizes.
• 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 🔒
• FrontierDelayDatum 🔒
• FrontierDelayState 🔒
  State for tracking import-export frontier lag.
• ImportFrontierDatum 🔒
• Peek
  A logged peek event.
• PeekDatum 🔒
• PeekDurationDatum 🔒
• RetractImportFrontiers 🔒

Enums

• ComputeEvent
  A logged compute event.
• PeekType

Traits

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

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 🔒