Struct AckToken 

pub struct AckToken { /* private fields */ }

A token representing a batch of events that requires acknowledgement.

When an event batch is successfully written to a sink (or dropped intentionally by a transform), this token is triggered to notify the original source that it can commit the batch (e.g., commit Kafka offsets).

Implementations

impl AckToken

pub fn new(notifier: Arc<dyn BatchNotifier>) -> Self

Creates a new AckToken wrapping the given notifier.

pub fn split(self, n: usize) -> Vec<AckToken>

Splits this token into n tokens.

The underlying notifier will only be called after all n tokens have been acknowledged. This is used by the Fanout mechanism to ensure all downstream components have processed the batch before acknowledging it to the source.

If n is 0, the original token is effectively acknowledged immediately. If n is 1, it returns itself.

pub fn ack(self)

Acknowledges the batch.

Only when all split tokens have been acknowledged will the underlying notifier be triggered.

pub fn is_acknowledged(&self) -> bool

Returns true if this token has been fully acknowledged.

Trait Implementations

impl Clone for AckToken

fn clone(&self) -> AckToken

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AckToken

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

Formats the value using the given formatter.

impl PartialEq for AckToken

fn eq(&self, other: &Self) -> 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 Eq for AckToken