Struct ConsumerPresence 

pub struct ConsumerPresence {
    pub queue: String,
    pub group: String,
    pub consumer: String,
    pub registered_at_ns: u64,
    pub last_heartbeat_ns: u64,
    pub last_seen_age_ms: u64,
    pub lease_count: u32,
    pub state: PresenceState,
}

One row of presence state, returned by snapshot.

Fields

queue: String

group: String

consumer: String

registered_at_ns: u64

last_heartbeat_ns: u64

last_seen_age_ms: u64

now_ns - last_heartbeat_ns, milliseconds. Snapshotted at read time so the UI does not have to derive it.

lease_count: u32

Caller-reported number of in-flight (locked but unacked) messages for this consumer. Stored verbatim — the registry does not cross-check it against the live PEL because the presence contract is intentionally independent of pending delivery state.

state: PresenceState

Trait Implementations

impl Clone for ConsumerPresence

fn clone(&self) -> ConsumerPresence

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerPresence

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

Formats the value using the given formatter.

impl PartialEq for ConsumerPresence

fn eq(&self, other: &ConsumerPresence) -> 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 Eq for ConsumerPresence

impl StructuralPartialEq for ConsumerPresence