Struct PendingAck 

pub struct PendingAck {
    pub message_id: MessageId,
    pub sent_at: DateTime<Utc>,
    pub timeout_ms: u64,
    pub status: AckStatus,
    pub retry_count: u32,
    pub priority: MessagePriority,
    pub extended_ms: u64,
}

Information about a pending ACK.

Fields

message_id: MessageId

Message ID waiting for ACK.

sent_at: DateTime<Utc>

When the message was sent.

timeout_ms: u64

Timeout for this ACK (in milliseconds).

status: AckStatus

Current status.

retry_count: u32

Number of times the message has been retried.

priority: MessagePriority

Priority of the message (for eviction decisions).

extended_ms: u64

How far the deadline has been pushed past sent_at + timeout_ms while the frame was still waiting in a local transport queue. Kept apart from sent_at, which the sender reads to measure the round trip, and reset on every new attempt.

Implementations

impl PendingAck

pub fn is_timed_out(&self) -> bool

Checks if this ACK has timed out.

Trait Implementations

impl Clone for PendingAck

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 PendingAck

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

Formats the value using the given formatter.