pub struct State {
pub bytes: Option<i32>,
pub consumer_count: Option<i32>,
pub first_seq: Option<i32>,
pub first_ts: Option<String>,
pub last_seq: Option<i32>,
pub last_ts: Option<String>,
pub messages: Option<i32>,
pub num_deleted: Option<i32>,
pub num_subjects: Option<i32>,
}Fields§
§bytes: Option<i32>Bytes is the total stored size.
consumer_count: Option<i32>Consumers is the number of consumers attached to this stream.
first_seq: Option<i32>FirstSeq is the sequence of the first stored message.
first_ts: Option<String>FirstTS is the timestamp of the first stored message.
last_seq: Option<i32>LastSeq is the sequence of the last stored message.
last_ts: Option<String>LastTS is the timestamp of the last stored message.
messages: Option<i32>Messages is the number of messages currently stored.
num_deleted: Option<i32>Deleted is the number of deleted messages (sequence gaps).
num_subjects: Option<i32>Subjects is the number of distinct subjects stored.
Implementations§
Trait Implementations§
Source§impl<'de> Deserialize<'de> for State
impl<'de> Deserialize<'de> for State
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl StructuralPartialEq for State
Auto Trait Implementations§
impl Freeze for State
impl RefUnwindSafe for State
impl Send for State
impl Sync for State
impl Unpin for State
impl UnsafeUnpin for State
impl UnwindSafe for State
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more