Struct ActorRegistry 

pub struct ActorRegistry<R: Reactor> { /* private fields */ }

Central registry for all actors in the engine (REQ-014).

Uses sharded concurrent maps for deterministic iteration order (shard 0..16, insertion order within each shard) while still supporting concurrent access.

Implementations

impl<R: Reactor> ActorRegistry<R>

pub fn new() -> Self

pub fn next_generation(&self) -> u64

Assign a unique generation ID for a new actor.

pub fn insert(&self, slot: ActorSlot<R>)

pub fn remove(&self, addr: AddrHash) -> Option<Arc<ActorSlot<R>>>

pub fn get_by_addr(&self, addr: AddrHash) -> Option<Arc<ActorSlot<R>>>

pub fn get_by_path(&self, path: &ActorPath) -> Option<Arc<ActorSlot<R>>>

pub fn update_running(&self, addr: AddrHash, running: bool)

pub fn increment_restart_count(&self, addr: AddrHash)

Increment the restart counter for an actor (called by supervisor on restart).

Trait Implementations

impl<R: Reactor> Default for ActorRegistry<R>

fn default() -> Self

Returns the “default value” for a type.