Skip to content

src/dazzle_back/metrics/backlog.py

Generated: 2026-03-30T04:38:46.378526+00:00

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose

Backlog tracker for consumer lag measurement.

Tracks the difference between produced and consumed sequence numbers to measure consumer lag and backpressure.

Key Exports

  • BacklogStats
  • ConsumerBacklog
  • BacklogTracker
  • current_lag
  • update_producer
  • update_consumer
  • stats
  • reset
  • to_dict
  • update_producer
  • update_consumer
  • register_consumer
  • get
  • all_stats
  • by_stream
  • total_lag
  • max_lag
  • growth_rate
  • to_dict
  • reset_all

Dependencies

Imports

  • __future__.annotations
  • threading
  • time
  • dataclasses.dataclass
  • dataclasses.field
  • typing.Any

Event Interactions

None detected.

Invariants and Assumptions

No invariants documented.

Tests

No related tests found.

Notes

This page was automatically generated by tools/gen_reference_docs.py.