Struct StreamDelivery 

pub struct StreamDelivery {
    pub stream_seq: u64,
    pub delivery_count: u64,
    pub message: Message,
}

Fields

stream_seq: u64

delivery_count: u64

How many times this message has been delivered to this durable, counting this delivery: 1 on the first delivery, and one more after every nak or ack-wait expiry. JetStream reports it as num_delivered.

On a stream whose max-deliver is unlimited this is the only way a consumer can tell a message that keeps failing from a new one, so it is what a consumer uses to give up and StreamCursor::term it.

message: Message

Trait Implementations

impl Clone for StreamDelivery

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 StreamDelivery

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

Formats the value using the given formatter.

impl Eq for StreamDelivery

impl PartialEq for StreamDelivery

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamDelivery