Struct nats::jetstream::ConsumerInfo
source · pub struct ConsumerInfo {
pub stream_name: String,
pub name: String,
pub created: DateTime,
pub config: ConsumerConfig,
pub delivered: SequencePair,
pub ack_floor: SequencePair,
pub num_ack_pending: usize,
pub num_redelivered: usize,
pub num_waiting: usize,
pub num_pending: u64,
pub cluster: ClusterInfo,
pub push_bound: bool,
}
Expand description
Information about a consumer
Fields§
§stream_name: String
The stream being consumed
name: String
The consumer’s unique name
created: DateTime
The time the consumer was created
config: ConsumerConfig
The consumer’s configuration
delivered: SequencePair
Statistics for delivered messages
ack_floor: SequencePair
Statistics for acknowledged messages
num_ack_pending: usize
The difference between delivered and acknowledged messages
num_redelivered: usize
The number of messages re-sent after acknowledgment was not received within the configured time threshold
num_waiting: usize
The number of waiting
num_pending: u64
The number of pending
cluster: ClusterInfo
Information about the consumer’s cluster
push_bound: bool
Indicates if any client is connected and receiving messages from a push consumer
Trait Implementations§
source§impl Clone for ConsumerInfo
impl Clone for ConsumerInfo
source§fn clone(&self) -> ConsumerInfo
fn clone(&self) -> ConsumerInfo
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ConsumerInfo
impl Debug for ConsumerInfo
source§impl<'de> Deserialize<'de> for ConsumerInfo
impl<'de> Deserialize<'de> for ConsumerInfo
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
source§impl PartialEq for ConsumerInfo
impl PartialEq for ConsumerInfo
source§fn eq(&self, other: &ConsumerInfo) -> bool
fn eq(&self, other: &ConsumerInfo) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for ConsumerInfo
impl Serialize for ConsumerInfo
impl Eq for ConsumerInfo
impl StructuralPartialEq for ConsumerInfo
Auto Trait Implementations§
impl Freeze for ConsumerInfo
impl RefUnwindSafe for ConsumerInfo
impl Send for ConsumerInfo
impl Sync for ConsumerInfo
impl Unpin for ConsumerInfo
impl UnwindSafe for ConsumerInfo
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