Struct nats::jetstream::StreamState [−][src]
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
[src]
impl Clone for StreamState
[src]fn clone(&self) -> StreamState
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for StreamState
[src]
impl Copy for StreamState
[src]impl Default for StreamState
[src]
impl Default for StreamState
[src]fn default() -> StreamState
[src]
impl<'de> Deserialize<'de> for StreamState
[src]
impl<'de> Deserialize<'de> for StreamState
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for StreamState
[src]
impl Serialize for StreamState
[src]Auto Trait Implementations
impl RefUnwindSafe for StreamState
impl RefUnwindSafe for StreamState
impl Send for StreamState
impl Send for StreamState
impl Sync for StreamState
impl Sync for StreamState
impl Unpin for StreamState
impl Unpin for StreamState
impl UnwindSafe for StreamState
impl UnwindSafe for StreamState
Blanket Implementations
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,