Struct LoggingDispatcher 

pub struct LoggingDispatcher { /* private fields */ }

Logging-only dispatcher. Records every admitted action in an internal Mutex<Vec<MeshOsAction>> and returns Ok(()). Useful for bootstrap (before real subsystem wiring lands) + the executor’s unit tests.

Implementations

impl LoggingDispatcher

pub fn new() -> Self

Construct an empty logger.

pub fn log(&self) -> Vec<MeshOsAction>

Snapshot of the actions dispatched so far.

pub fn fail_next(&self, err: DispatchError)

Inject an error to surface on the next dispatch call. Used by tests to exercise the retry / drop paths.

pub fn backpressure_log(&self) -> Vec<ClusterBackpressureChange>

Snapshot of the cluster-backpressure transitions the executor has surfaced through on_cluster_backpressure.

Trait Implementations

impl ActionDispatcher for LoggingDispatcher

fn dispatch<'a>( &'a self, action: MeshOsAction, ) -> BoxFuture<'a, Result<(), DispatchError>>

Dispatch an admitted action. Errors record on the recent-failures ring buffer; the action is not retried (admit / defer is the retry surface).

fn on_cluster_backpressure(&self, change: ClusterBackpressureChange)

Cluster-wide backpressure flag transitioned. The executor invokes this once per edge crossing — Asserted when the action-queue depth crosses the high-water mark, Released when it drops below the low-water mark. Production dispatchers fan DaemonControl::BackpressureOn { level } / DaemonControl::BackpressureOff out to supervised daemons so they can shed optional work. Default impl is a no-op — dispatchers that don’t supervise daemons (e.g. the test logger) can ignore the hook.

impl Debug for LoggingDispatcher

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

Formats the value using the given formatter.

impl Default for LoggingDispatcher

fn default() -> LoggingDispatcher

Returns the “default value” for a type.