Struct nats::jetstream::JetStreamMessageInfo

pub struct JetStreamMessageInfo<'a> {
    pub domain: Option<&'a str>,
    pub acc_hash: Option<&'a str>,
    pub stream: &'a str,
    pub consumer: &'a str,
    pub stream_seq: u64,
    pub consumer_seq: u64,
    pub delivered: i64,
    pub pending: u64,
    pub published: DateTime,
    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_seq: u64

The stream sequence number associated with this message

consumer_seq: u64

The consumer sequence number associated with this message

delivered: i64

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

pending: u64

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

published: DateTime

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 JetStreamMessageInfo<'a>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for JetStreamMessageInfo<'a>

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

Formats the value using the given formatter.