Struct Drain 

pub struct Drain { /* private fields */ }

The running drain: owns the two worker/forwarder/loop threads. Dropping (or shutdown) stops the loop; the forwarder exits when the cluster’s channel-out closes (i.e. when the Cluster is dropped).

Implementations

impl Drain

pub fn spawn<S: DrainSink + 'static>( events: Receiver<ClusterEvent>, initial_cv: u64, sink: S, ) -> Drain

Spawn the drain over a cluster’s channel-out events, with initial_cv the replica’s committed watermark at open (the progress frontier) and sink the delivery target. Returns the handle plus a DrainHandle for the coordinator.

pub fn handle(&self) -> DrainHandle

A coordinator-side control handle (cheap clone).

pub fn shutdown(self)

Stop the loop and join it. The forwarder is left to exit on cluster close.

Trait Implementations

impl Drop for Drain

fn drop(&mut self)

Executes the destructor for this type.