Struct AckSet 

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

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

A bare AckRef resolves Delivered on drop — the right default for records, where drop means “consumed” (filtered out, skipped by policy, or written). Collections travelling the sink path are different: there, 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 always safe under at-least-once — it costs replay, never 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: 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.