pub type Acker = Arc<dyn Fn(u64) + Send + Sync>;Expand description
Acks an epoch’s barrier from off the sink’s thread: a sink whose durability lands elsewhere (a
file committer syncing parts, a table commit) withholds the ack in on_barrier and calls this
once the epoch is durable — under its own task id, which the runtime binds in.
Aliased Type§
pub struct Acker { /* private fields */ }