Struct ActorRegistry 

pub struct ActorRegistry { /* private fields */ }

Actor registry for tracking actors.

Implementations

impl ActorRegistry

pub fn new() -> Self

Create a new actor registry.

pub fn with_mailbox_config(config: MailboxConfig) -> Self

Create a new registry with custom mailbox config.

pub fn register(&self, id: ActorId) -> Result<Arc<Mailbox>>

Register a new actor.

pub fn register_named( &self, id: ActorId, name: Option<String>, ) -> Result<Arc<Mailbox>>

Register a new actor with a name.

This operation is fully atomic: both the ID and name mappings are created (or rejected) under a single critical section. The by_name write lock serializes all registrations, preventing TOCTOU races where a concurrent registration could observe or corrupt partial state.

pub fn unregister(&self, id: &ActorId) -> Result<()>

Unregister an actor.

pub fn get_mailbox(&self, id: &ActorId) -> Option<Arc<Mailbox>>

Get an actor’s mailbox by ID.

pub fn get_state(&self, id: &ActorId) -> Option<ActorState>

Get an actor’s state by ID.

pub fn set_state(&self, id: &ActorId, state: ActorState) -> Result<()>

Set an actor’s state.

pub fn lookup(&self, name: &str) -> Option<ActorId>

Look up an actor by name.

pub fn lookup_mailbox(&self, name: &str) -> Option<Arc<Mailbox>>

Look up an actor’s mailbox by name.

pub fn record_processed(&self, id: &ActorId)

Record a message processed by an actor.

pub fn get_processed_count(&self, id: &ActorId) -> u64

Get the number of messages processed by an actor.

pub fn get_last_active(&self, id: &ActorId) -> Option<i64>

Get the last activity timestamp for an actor.

pub fn len(&self) -> usize

Get the total number of actors.

pub fn is_empty(&self) -> bool

Check if the registry is empty.

pub fn list_actors(&self) -> Vec<ActorId>

List all actor IDs.

pub fn list_by_state(&self, state: ActorState) -> Vec<ActorId>

List actors by state.

pub fn stats(&self) -> RegistryStats

Get statistics about the registry.

Trait Implementations

impl Default for ActorRegistry

fn default() -> Self

Returns the “default value” for a type.