Struct AckIssuer 

pub struct AckIssuer { /* private fields */ }

Creates acknowledgement handles on pipeline threads.

One issuer per pipeline thread. Within an epoch, a partition must be issued from exactly one issuer (the runtime guarantees this: a partition is owned by exactly one thread) — sequence numbering is issuer-local. Cloning yields an issuer with fresh sequence state for use by another thread and another set of partitions.

Implementations

impl AckIssuer

pub fn issue(&mut self, partition: PartitionId, last_offset: i64) -> AckRef

Issue the acknowledgement handle for a new source poll batch whose highest contained offset is last_offset.

Wait-free: one atomic load, one unbounded send, one allocation for the batch’s shared state.

Trait Implementations

impl Clone for AckIssuer

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 AckIssuer

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

Formats the value using the given formatter.