Struct DrainConsumer 

pub struct DrainConsumer { /* private fields */ }

Implementations

impl DrainConsumer

pub fn new( client: DrainClient, recipient: HqRecipientSecret, stream: NodeStream, handler: CoreHandler, ) -> Self

pub fn with_cursor_dir(self, dir: Option<PathBuf>) -> Self

Persist the last ACK under dir and start from the stored value.

pub fn with_outbound(self, rx: Receiver<Vec<u8>>) -> Self

Attach a queue of core-initiated plaintexts (see node_controller::OperatorLink).

pub fn last_acked(&self) -> u64

pub async fn run(self, shutdown: Receiver<bool>)

Drain until shutdown, reconnecting with RESUME after the last ACK.