Struct async_nats::jetstream::message::Info

pub struct Info<'a> {
    pub domain: Option<&'a str>,
    pub acc_hash: Option<&'a str>,
    pub stream: &'a str,
    pub consumer: &'a str,
    pub stream_sequence: u64,
    pub consumer_sequence: u64,
    pub delivered: i64,
    pub pending: u64,
    pub published: OffsetDateTime,
    pub token: Option<&'a str>,
}

Information about a received message

Fields

domain: Option<&'a str>

Optional domain, present in servers post-ADR-15

acc_hash: Option<&'a str>

Optional account hash, present in servers post-ADR-15

stream: &'a str

The stream name

consumer: &'a str

The consumer name

stream_sequence: u64

The stream sequence number associated with this message

consumer_sequence: u64

The consumer sequence number associated with this message

delivered: i64

The number of delivery attempts for this message

pending: u64

the number of messages known by the server to be pending to this consumer

published: OffsetDateTime

the time that this message was received by the server from its publisher

token: Option<&'a str>

Optional token, present in servers post-ADR-15

Trait Implementations

impl<'a> Clone for Info<'a>

fn clone(&self) -> Info<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Info<'a>

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

Formats the value using the given formatter.