Struct DrainBarrier 

pub struct DrainBarrier { /* private fields */ }

A countdown barrier the controller waits on while pipeline threads drain. Created with the number of arriving parties (the threads that own the lanes being stopped); each thread calls DrainBarrier::arrive exactly once after it has stopped the lanes and flushed its in-flight records; the controller’s DrainBarrier::wait returns true once all parties arrived, or false on timeout (drain deadline exceeded — the caller proceeds and unflushed data replays after restart; at-least-once holds either way).

Implementations

impl DrainBarrier

pub fn new(parties: usize) -> DrainBarrier

A barrier expecting parties arrivals. parties == 0 is complete immediately.

pub fn arrive(&self)

Record this party’s drain as complete. Idempotence is the caller’s responsibility: call exactly once per party.

pub fn remaining(&self) -> usize

Parties still outstanding.

pub fn wait(&self, timeout: Duration) -> bool

Block until every party arrived or timeout elapsed. Returns whether the drain completed.

Trait Implementations

impl Clone for DrainBarrier

fn clone(&self) -> DrainBarrier

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DrainBarrier

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

Formats the value using the given formatter.