Struct SequenceInfo

pub struct SequenceInfo {
    pub consumer_sequence: u64,
    pub stream_sequence: u64,
    pub last_active: Option<OffsetDateTime>,
}

Information about a consumer and the stream it is consuming

Fields

consumer_sequence: u64

How far along the consumer has progressed

stream_sequence: u64

The aggregate for all stream consumers

last_active: Option<OffsetDateTime>

Trait Implementations

impl Clone for SequenceInfo

fn clone(&self) -> SequenceInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SequenceInfo

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SequenceInfo

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SequenceInfo

fn eq(&self, other: &SequenceInfo) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for SequenceInfo

impl Eq for SequenceInfo

impl StructuralPartialEq for SequenceInfo