Struct AckSet 

pub struct AckSet(/* private fields */);

A fail-safe collection of acknowledgment handles for data that has not been durably written yet (encoded chunks, sink batches).

A bare AckRef resolves Delivered on drop, the default for records, where drop means “consumed” (filtered out, skipped by policy, or written). On the sink path, drop without an explicit outcome means the data was torn down (task aborted, queue dropped, worker cancelled), and resolving Delivered would commit offsets for rows that never reached the sink. AckSet therefore fails every handle it still holds when dropped; the happy path calls AckSet::deliver after the durable write. Over-failing is safe under at-least-once, costing replay rather than loss.

Implementations

impl AckSet

pub fn new() -> Self

An empty set.

pub fn push(&mut self, ack: AckRef)

Add a handle to the set.

pub fn absorb(&mut self, other: AckSet)

Move every handle out of other into self.

pub fn is_empty(&self) -> bool

Whether the set holds no handles.

pub fn len(&self) -> usize

Number of handles held.

pub fn deliver(self)

Resolve the set as delivered, meaning the data it covers is durably written. Consumes the set; the handles drop with their default (Delivered) resolution.

Trait Implementations

impl Debug for AckSet

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

Formats the value using the given formatter.

impl Default for AckSet

fn default() -> AckSet

Returns the “default value” for a type.

impl Drop for AckSet

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl From<Vec<AckRef>> for AckSet

fn from(acks: Vec<AckRef>) -> Self

Converts to this type from the input type.