Struct ActorRegistry 

pub struct ActorRegistry { /* private fields */ }

Implementations

impl ActorRegistry

pub fn new(bus: TelemetryBus) -> Self

pub fn record_spawn(&self, status: ActorStatus)

pub fn record_stop(&self, path: &str)

pub fn record_mailbox_depth(&self, path: &str, depth: u64)

pub fn total_spawned(&self) -> u64

pub fn total_stopped(&self) -> u64

pub fn live_count(&self) -> u64

pub fn snapshot(&self) -> ActorSnapshot

Trait Implementations

impl SpawnObserver for ActorRegistry

fn on_spawn( &self, path: &ActorPath, parent: Option<&ActorPath>, actor_type: &'static str, )

fn on_stop(&self, path: &ActorPath)

fn on_mailbox_depth(&self, path: &ActorPath, depth: u64)

Called whenever the mailbox depth is sampled (optional).