Struct ProcessCoalescingState 

pub struct ProcessCoalescingState {
    pub active_leaders: usize,
    pub active_followers: usize,
    pub oldest_leader_age_ms: Option<u64>,
}

Exact process-scoped single-flight state of one instance.

Fields

active_leaders: usize

Executions currently in flight on this instance, one per logical key.

active_followers: usize

Callers currently waiting on those executions instead of running their own.

oldest_leader_age_ms: Option<u64>

Milliseconds since the oldest in-flight execution started; None when nothing is in flight.

Trait Implementations

impl Clone for ProcessCoalescingState

fn clone(&self) -> ProcessCoalescingState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessCoalescingState

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

Formats the value using the given formatter.

impl Default for ProcessCoalescingState

fn default() -> ProcessCoalescingState

Returns the “default value” for a type.

impl Eq for ProcessCoalescingState

impl PartialEq for ProcessCoalescingState

fn eq(&self, other: &ProcessCoalescingState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ProcessCoalescingState