Struct ReplayWorkerManager 

pub struct ReplayWorkerManager { /* private fields */ }

Implementations

impl ReplayWorkerManager

pub fn new() -> Self

pub fn insert(&mut self, target_id: String, cancel_tx: Sender<()>)

Registers a cancel channel without a join handle.

Used where the worker’s lifetime is managed elsewhere (or in tests). Such workers are signalled on stop_all but not awaited. Prefer Self::insert_with_handle for in-process workers so shutdown can join them and avoid orphaned tasks.

pub fn insert_with_handle( &mut self, target_id: String, cancel_tx: Sender<()>, join: JoinHandle<()>, )

Registers a cancel channel together with the worker’s join handle so stop_all can await the worker’s exit.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn snapshot(&self, target_count: usize) -> RuntimeStatusSnapshot

pub async fn stop_all(&mut self, log_prefix: &str)

Stops every replay worker: it first signals cancellation to all of them, then strictly awaits each worker’s exit. A worker already awaiting a delivery acknowledgement is allowed to finish; aborting it at an arbitrary deadline could leave an acknowledged queue entry undeleted and make the replacement worker deliver it again. Signalling before joining lets all workers wind down concurrently. Legacy joinless registrations can only be signalled.

Trait Implementations

impl Debug for ReplayWorkerManager

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

Formats the value using the given formatter.

impl Default for ReplayWorkerManager

fn default() -> ReplayWorkerManager

Returns the “default value” for a type.