miniproto.media.scheduler.MediaSchedulerSnapshot

miniproto.media.scheduler.MediaSchedulerSnapshot

MediaSchedulerSnapshot(max_bytes: int, active_bytes: int, queued_bytes: int, active_transfers: int, queued_transfers: int, grants: int, grants_by_transfer: dict[str, int]) -> None

Immutable byte and operation measurements for one DC/direction scheduler.

Attributes:

• max_bytes (int) – Per-data-centre and direction byte ceiling in bytes.
• active_bytes (int) – Charged bytes reserved by unreleased permits.
• queued_bytes (int) – Charged bytes waiting for a permit.
• active_transfers (int) – Transfers with at least one live permit.
• queued_transfers (int) – Transfers with at least one queued acquire.
• grants (int) – Total permits granted by this scheduler since creation.
• grants_by_transfer (dict[str, int]) – Copy of total grants keyed by transfer identifier.