Struct SourceOffset 

pub struct SourceOffset { /* private fields */ }

The source coordinates of one delivery, as EosPipeline::publish needs them.

In a handler, take them as a Ctx(source): Ctx<Source> extractor parameter, or read the keys::Source field off a declared ctx parameter.

Implementations

impl SourceOffset

pub fn new(topic: impl Into<String>, partition: i32, offset: i64) -> Self

Builds the coordinates by hand; in a handler prefer the keys::Source key.

Trait Implementations

impl Clone for SourceOffset

fn clone(&self) -> SourceOffset

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceOffset

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

Formats the value using the given formatter.

impl Eq for SourceOffset

impl PartialEq for SourceOffset

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceOffset