Struct ActorRegistry 

pub struct ActorRegistry { /* private fields */ }

Thread-safe registry of all live actors.

Implementations

impl ActorRegistry

pub fn new() -> Self

pub async fn register(&self, entry: ActorEntry)

Register a new actor entry.

pub async fn deregister(&self, id: &str)

Deregister an actor by WID.

pub async fn get(&self, id: &str) -> Option<ActorEntry>

Look up an actor entry by WID.

pub async fn get_by_name(&self, name: &str) -> Option<ActorEntry>

Look up an actor by name.

pub async fn list(&self) -> Vec<ActorEntry>

Return a snapshot of all registered actors.

pub async fn update_state(&self, id: &str, state: ActorState)

Update the stored ActorState for an actor.

pub async fn send(&self, id: &str, message: Message) -> Result<()>

Send a message directly to an actor’s mailbox.

pub async fn broadcast(&self, message: Message)

Broadcast a message to all registered actors.

Trait Implementations

impl Clone for ActorRegistry

fn clone(&self) -> ActorRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActorRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ActorRegistry

fn default() -> ActorRegistry

Returns the “default value” for a type.