Struct Consumer 

pub struct Consumer {
    pub consumer_id: String,
    pub event_type_filters: Vec<String>,
    pub cursor_position: Option<u64>,
}

A durable consumer tracks a cursor (last-acknowledged position) so it can resume from where it left off after disconnection or restart.

Fields

consumer_id: String

event_type_filters: Vec<String>

Event type prefix filters (e.g. ["scheduler.*", "index.*"]). Empty means “all events”.

cursor_position: Option<u64>

Global event offset of the last acknowledged event. Events after this offset are “unprocessed” for this consumer. None means the consumer hasn’t acked anything yet (start from beginning).

Trait Implementations

impl Clone for Consumer

fn clone(&self) -> Consumer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Consumer

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Consumer

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Consumer

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

where __S: Serializer,

Serialize this value into the given Serde serializer.