Trait CuMonitor 

pub trait CuMonitor: Sized {
    // Required methods
    fn new(
        config: &CuConfig,
        taskids: &'static [&'static str],
    ) -> Result<Self, CuError>
       where Self: Sized;
    fn process_copperlist(
        &self,
        _ctx: &CuContext,
        msgs: &[&CuMsgMetadata],
    ) -> Result<(), CuError>;
    fn process_error(
        &self,
        taskid: usize,
        step: CuTaskState,
        error: &CuError,
    ) -> Decision;

    // Provided methods
    fn set_topology(&mut self, _topology: MonitorTopology) { ... }
    fn set_copperlist_info(&mut self, _info: CopperListInfo) { ... }
    fn set_execution_probe(&mut self, _probe: Arc<RuntimeExecutionProbe>) { ... }
    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> { ... }
}

Trait to implement a monitoring task.

Required Methods

fn new( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<Self, CuError>

where Self: Sized,

fn process_copperlist( &self, _ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

Callback that will be trigger at the end of every copperlist (before, on or after the serialization).

fn process_error( &self, taskid: usize, step: CuTaskState, error: &CuError, ) -> Decision

Callbacked when a Task errored out. The runtime requires an immediate decision.

Provided Methods

fn set_topology(&mut self, _topology: MonitorTopology)

fn set_copperlist_info(&mut self, _info: CopperListInfo)

fn set_execution_probe(&mut self, _probe: Arc<RuntimeExecutionProbe>)

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

fn observe_copperlist_io(&self, _stats: CopperListIoStats)

Called when the runtime finishes serializing a CopperList, giving IO accounting data.

fn process_panic(&self, _panic_message: &str)

Callback fired when the runtime catches a panic in a std build.

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

Callbacked when copper is stopping.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

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

where M0: CuMonitor, M1: CuMonitor,

fn new( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<(M0, M1), CuError>

where (M0, M1): Sized,

fn set_topology(&mut self, topology: MonitorTopology)

fn set_copperlist_info(&mut self, info: CopperListInfo)

fn set_execution_probe(&mut self, probe: Arc<RuntimeExecutionProbe>)

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

fn process_copperlist( &self, ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, taskid: usize, step: CuTaskState, 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( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<(M0, M1, M2), CuError>

where (M0, M1, M2): Sized,

fn set_topology(&mut self, topology: MonitorTopology)

fn set_copperlist_info(&mut self, info: CopperListInfo)

fn set_execution_probe(&mut self, probe: Arc<RuntimeExecutionProbe>)

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

fn process_copperlist( &self, ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, taskid: usize, step: CuTaskState, 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( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<(M0, M1, M2, M3), CuError>

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

fn set_topology(&mut self, topology: MonitorTopology)

fn set_copperlist_info(&mut self, info: CopperListInfo)

fn set_execution_probe(&mut self, probe: Arc<RuntimeExecutionProbe>)

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

fn process_copperlist( &self, ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, taskid: usize, step: CuTaskState, 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( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<(M0, M1, M2, M3, M4), CuError>

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

fn set_topology(&mut self, topology: MonitorTopology)

fn set_copperlist_info(&mut self, info: CopperListInfo)

fn set_execution_probe(&mut self, probe: Arc<RuntimeExecutionProbe>)

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

fn process_copperlist( &self, ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, taskid: usize, step: CuTaskState, 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( config: &CuConfig, taskids: &'static [&'static str], ) -> Result<(M0, M1, M2, M3, M4, M5), CuError>

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

fn set_topology(&mut self, topology: MonitorTopology)

fn set_copperlist_info(&mut self, info: CopperListInfo)

fn set_execution_probe(&mut self, probe: Arc<RuntimeExecutionProbe>)

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

fn process_copperlist( &self, ctx: &CuContext, msgs: &[&CuMsgMetadata], ) -> Result<(), CuError>

fn observe_copperlist_io(&self, stats: CopperListIoStats)

fn process_error( &self, taskid: usize, step: CuTaskState, error: &CuError, ) -> Decision

fn process_panic(&self, panic_message: &str)

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

Implementors

impl CuMonitor for NoMonitor