Struct EventSnapshotBuilder 

pub struct EventSnapshotBuilder { /* private fields */ }

Builder for EventSnapshot.

Either set fields explicitly, or fold a batch of Events into the running counts via EventSnapshotBuilder::observe / EventSnapshotBuilder::observe_all.

Implementations

impl EventSnapshotBuilder

pub fn new() -> Self

Create a new, empty snapshot builder.

pub fn timestamp(self, ts: DateTime<Utc>) -> Self

Set the snapshot timestamp (defaults to Utc::now at build time).

pub fn pending(self, n: u64) -> Self

Set the pending count.

pub fn active(self, n: u64) -> Self

Set the active count.

pub fn succeeded(self, n: u64) -> Self

Set the succeeded count.

pub fn failed(self, n: u64) -> Self

Set the failed count.

pub fn retried(self, n: u64) -> Self

Set the retried count.

pub fn revoked(self, n: u64) -> Self

Set the revoked count.

pub fn worker_count(self, n: u64) -> Self

Set the worker count explicitly (overrides workers inferred from events).

pub fn queue_depth(self, queue: impl Into<String>, depth: u64) -> Self

Set the depth for a specific queue (also adds to the total).

pub fn total_queue_depth(self, depth: u64) -> Self

Set the aggregate queue depth directly (when per-queue detail is absent).

pub fn observe(&mut self, event: &Event) -> &mut Self

Fold a single event into the running aggregate.

Task lifecycle events bump the corresponding counters; worker online/heartbeat events register a worker as present, and worker offline removes it.

pub fn observe_all<'a, I>(&mut self, events: I) -> &mut Self

where I: IntoIterator<Item = &'a Event>,

Fold a batch of events into the running aggregate.

pub fn build(self) -> EventSnapshot

Finalize the snapshot.

Trait Implementations

impl Clone for EventSnapshotBuilder

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventSnapshotBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for EventSnapshotBuilder

fn default() -> Self

Returns the “default value” for a type.