Struct AdaptiveIpcSidecar 

pub struct AdaptiveIpcSidecar { /* private fields */ }

Background scanner thread that drives family promotions on an AdaptiveIpc by polling AdaptiveIpc::maybe_promote on a timer.

spawn starts the thread; shutdown stops it cleanly. The thread polls every scan_interval, calls maybe_promote(), and counts a promotion when the call returns Ok(Some(_)).

Implementations

impl AdaptiveIpcSidecar

pub fn spawn<T: Marshal + Copy + Send + Sync + 'static>( ipc: Arc<AdaptiveIpc<T>>, scan_interval: Duration, ) -> Self

Spawn a sidecar thread that polls ipc.maybe_promote() every scan_interval. Each successful promotion is counted in promotions_triggered.

pub fn promotions_triggered(&self) -> u64

Number of successful promotions the sidecar has issued since spawn.

pub fn shutdown(self)

Stop the scanner thread and join it.

Trait Implementations

impl Drop for AdaptiveIpcSidecar

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.