Enum StreamOffset 

pub enum StreamOffset {
    Kafka {
        topic: String,
        partition: i32,
        offset: i64,
    },
    Redis {
        stream: String,
        id: String,
    },
    Nats {
        subject: String,
        sequence: u64,
    },
    Sequence(u64),
}

Offset within a stream (provider-specific).

Variants

Kafka

Kafka-style: topic + partition + offset.

Fields

topic: String

Kafka topic name.

partition: i32

Kafka partition number.

offset: i64

Offset within the partition.

Redis

Redis-style: stream name + message ID.

Fields

stream: String

Redis stream name.

id: String

Redis message ID.

Nats

NATS-style: subject + sequence.

Fields

subject: String

NATS subject name.

sequence: u64

Sequence number within the subject.

Sequence(u64)

Generic sequence number.

Trait Implementations

impl Clone for StreamOffset

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamOffset

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

Formats the value using the given formatter.

impl Eq for StreamOffset

impl Hash for StreamOffset

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamOffset

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamOffset