Struct nakadi_types::subscription::SubscriptionEventTypeStats

pub struct SubscriptionEventTypeStats {
    pub event_type: EventTypeName,
    pub partitions: Vec<SubscriptionEventTypePartitionStats>,
}

Statistics of one EventType within a context of subscription.

See also Nakadi Manual

Fields

event_type: EventTypeName

partitions: Vec<SubscriptionEventTypePartitionStats>

Implementations

impl SubscriptionEventTypeStats

pub fn unconsumed_events(&self) -> Option<usize>

Returns the number of unconsumed events for this event type

pub fn all_events_consumed(&self) -> bool

Returns true if all events on all partitions on all event types have been consumed.

pub fn unconsumed_stream_events(&self, for_stream: StreamId) -> Option<usize>

Returns the number of unconsumed events for this event type on the given stream

Trait Implementations

impl Clone for SubscriptionEventTypeStats

pub fn clone(&self) -> SubscriptionEventTypeStats

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionEventTypeStats

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionEventTypeStats

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

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionEventTypeStats

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

Serialize this value into the given Serde serializer.