activity

Bound event detail projections and aggregate recent outcomes in fixed buckets.

bedrock_server_manager.diagnostics.activity.bound_event_activity(activity: EventDiagnostics, *, records: int, details: int) → tuple[EventDiagnostics, bool]

Copy and limit nested records without mutating the event bus observation.

bedrock_server_manager.diagnostics.activity.bound_operations(activity: OperationActivity, *, records: int) → OperationActivity

Bound operation detail even when a provider returns an oversized view.

bedrock_server_manager.diagnostics.activity.bound_subscriptions(snapshot: EventSubscriptions, *, records: int, details: int) → EventSubscriptions

Bound both listener count and ordering-reference detail in support reports.

class bedrock_server_manager.diagnostics.activity.RecentOutcomes(clock: Callable[[], float]=<built-in function monotonic>)

Keep 31 ten-second buckets, independent of journal write availability.