Trait CuMonitor 

pub trait CuMonitor: Sized {
    // Required methods
    fn new(
        metadata: CuMonitoringMetadata,
        runtime: CuMonitoringRuntime,
    ) -> Result<Self, CuError>
       where Self: Sized;
    fn process_copperlist(
        &self,
        _ctx: &CuContext,
        view: CopperListView<'_>,
    ) -> Result<(), CuError>;
    fn process_error(
        &self,
        component_id: ComponentId,
        step: CuComponentState,
        error: &CuError,
    ) -> Decision;

    // Provided methods
    fn start(&mut self, _ctx: &CuContext) -> Result<(), CuError> { ... }
    fn observe_copperlist_io(&self, _stats: CopperListIoStats) { ... }
    fn process_panic(&self, _panic_message: &str) { ... }
    fn stop(&mut self, _ctx: &CuContext) -> Result<(), CuError> { ... }
}

Runtime monitoring contract implemented by monitor components.

Lifecycle:

1. CuMonitor::new is called once at runtime construction time.
2. CuMonitor::start is called once before the first runtime iteration.
3. For each iteration, CuMonitor::process_copperlist is called after component execution, then CuMonitor::observe_copperlist_io after serialization accounting.
4. CuMonitor::process_error is called synchronously when a monitored component step fails.
5. CuMonitor::process_panic is called when the runtime catches a panic (std builds).
6. CuMonitor::stop is called once during runtime shutdown.

Indexing model:

• process_error(component_id, ..) uses component indices into metadata.components().
• process_copperlist(..., view) iterates CopperList slots with resolved component identity.

Error policy:

• Decision::Ignore continues execution.
• Decision::Abort aborts the current operation (step/copperlist scope).
• Decision::Shutdown triggers runtime shutdown.

Required Methods

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<Self, CuError>

where Self: Sized,

Construct the monitor once, before component execution starts.

metadata contains mission/config/topology/static mapping information. runtime exposes dynamic runtime handles (for example execution probes). Use metadata.monitor_config() to decode monitor-specific parameters.

fn process_copperlist( &self, _ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

Called once per processed CopperList after component execution.

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

Called when a monitored component step fails; must return an immediate runtime decision.

component_id is an index into CuMonitoringMetadata::components.

Provided Methods

fn start(&mut self, _ctx: &CuContext) -> Result<(), CuError>

Called once before processing the first CopperList.

fn observe_copperlist_io(&self, _stats: CopperListIoStats)

Called when runtime finishes CopperList serialization/IO accounting.

fn process_panic(&self, _panic_message: &str)

Called when the runtime catches a panic (std builds).

fn stop(&mut self, _ctx: &CuContext) -> Result<(), CuError>

Called once during runtime shutdown.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<M0, M1> CuMonitor for (M0, M1)

where M0: CuMonitor, M1: CuMonitor,

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<(M0, M1), CuError>

where (M0, M1): Sized,

fn start(&mut self, ctx: &CuContext) -> Result<(), CuError>

fn process_copperlist( &self, ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

fn stop(&mut self, ctx: &CuContext) -> Result<(), CuError>

impl<M0, M1, M2> CuMonitor for (M0, M1, M2)

where M0: CuMonitor, M1: CuMonitor, M2: CuMonitor,

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<(M0, M1, M2), CuError>

where (M0, M1, M2): Sized,

fn start(&mut self, ctx: &CuContext) -> Result<(), CuError>

fn process_copperlist( &self, ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

fn stop(&mut self, ctx: &CuContext) -> Result<(), CuError>

impl<M0, M1, M2, M3> CuMonitor for (M0, M1, M2, M3)

where M0: CuMonitor, M1: CuMonitor, M2: CuMonitor, M3: CuMonitor,

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<(M0, M1, M2, M3), CuError>

where (M0, M1, M2, M3): Sized,

fn start(&mut self, ctx: &CuContext) -> Result<(), CuError>

fn process_copperlist( &self, ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

fn stop(&mut self, ctx: &CuContext) -> Result<(), CuError>

impl<M0, M1, M2, M3, M4> CuMonitor for (M0, M1, M2, M3, M4)

where M0: CuMonitor, M1: CuMonitor, M2: CuMonitor, M3: CuMonitor, M4: CuMonitor,

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<(M0, M1, M2, M3, M4), CuError>

where (M0, M1, M2, M3, M4): Sized,

fn start(&mut self, ctx: &CuContext) -> Result<(), CuError>

fn process_copperlist( &self, ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

fn stop(&mut self, ctx: &CuContext) -> Result<(), CuError>

impl<M0, M1, M2, M3, M4, M5> CuMonitor for (M0, M1, M2, M3, M4, M5)

where M0: CuMonitor, M1: CuMonitor, M2: CuMonitor, M3: CuMonitor, M4: CuMonitor, M5: CuMonitor,

fn new( metadata: CuMonitoringMetadata, runtime: CuMonitoringRuntime, ) -> Result<(M0, M1, M2, M3, M4, M5), CuError>

where (M0, M1, M2, M3, M4, M5): Sized,

fn start(&mut self, ctx: &CuContext) -> Result<(), CuError>

fn process_copperlist( &self, ctx: &CuContext, view: CopperListView<'_>, ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, component_id: ComponentId, step: CuComponentState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

fn stop(&mut self, ctx: &CuContext) -> Result<(), CuError>

Implementors

impl CuMonitor for NoMonitor