Struct nats::jetstream::ConsumerInfo [−][src]
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, }
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 acknowleged messages
num_ack_pending: usize
The difference between delivered and acknowledged messages
num_redelivered: usize
The number of messages re-sent after acknowledgement 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
Trait Implementations
impl Clone for ConsumerInfo
[src]
impl Clone for ConsumerInfo
[src]fn clone(&self) -> ConsumerInfo
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Default for ConsumerInfo
[src]
impl Default for ConsumerInfo
[src]fn default() -> ConsumerInfo
[src]
impl<'de> Deserialize<'de> for ConsumerInfo
[src]
impl<'de> Deserialize<'de> for ConsumerInfo
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for ConsumerInfo
[src]
impl Serialize for ConsumerInfo
[src]Auto Trait Implementations
impl RefUnwindSafe for ConsumerInfo
impl RefUnwindSafe for ConsumerInfo
impl Send for ConsumerInfo
impl Send for ConsumerInfo
impl Sync for ConsumerInfo
impl Sync for ConsumerInfo
impl Unpin for ConsumerInfo
impl Unpin for ConsumerInfo
impl UnwindSafe for ConsumerInfo
impl UnwindSafe for ConsumerInfo
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>,