Struct nats::jetstream::StreamState

pub struct StreamState {
    pub messages: u64,
    pub bytes: u64,
    pub first_seq: u64,
    pub first_ts: DateTime,
    pub last_seq: u64,
    pub last_ts: DateTime,
    pub consumer_count: usize,
}

information about the given stream.

Fields

messages: u64

The number of messages contained in this stream

bytes: u64

The number of bytes of all messages contained in this stream

first_seq: u64

The lowest sequence number still present in this stream

first_ts: DateTime

The time associated with the oldest message still present in this stream

last_seq: u64

The last sequence number assigned to a message in this stream

last_ts: DateTime

The time that the last message was received by this stream

consumer_count: usize

The number of consumers configured to consume this stream

Trait Implementations

impl Clone for StreamState

fn clone(&self) -> StreamState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for StreamState

impl Debug for StreamState

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

Formats the value using the given formatter.

impl Default for StreamState

fn default() -> StreamState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.