Struct MetricsSystem 

pub struct MetricsSystem { /* private fields */ }

System that processes metrics events with hooks

This system:

1. Processes metric definition requests
2. Processes metric recording requests
3. Processes snapshot and report generation requests
4. Calls hooks for custom behavior
5. Publishes state change events for network replication

Implementations

impl MetricsSystem

pub fn new(hook: Arc<dyn MetricsHook>) -> Self

Create a new MetricsSystem with a custom hook

pub async fn process_events( &mut self, _services: &ServiceContext, resources: &mut ResourceContext, )

Process all metrics events

Trait Implementations

impl Clone for MetricsSystem

fn clone(&self) -> MetricsSystem

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl System for MetricsSystem

fn name(&self) -> &'static str

System name (must be unique)

fn as_any(&self) -> &dyn Any

Downcast to Any for type-safe access

fn as_any_mut(&mut self) -> &mut dyn Any

Downcast to Any for type-safe mutable access

fn initialize<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Initialize system (called once at startup)

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Optional: Shutdown cleanup