Struct ActorRegistry 

pub struct ActorRegistry { /* private fields */ }

In-memory projection of registered remote actors.

Reconstructed from WAL events at bootstrap via ActorRegistry::register and ActorRegistry::deregister calls. Maintains a secondary index of actors per tenant for O(N_tenant) lookups.

Implementations

impl ActorRegistry

pub fn new() -> Self

Creates an empty registry.

pub fn register(&mut self, registration: ActorRegistration)

Registers an actor. If an actor with this ID already exists, it is replaced.

pub fn deregister(&mut self, actor_id: ActorId)

Marks an actor as deregistered (inactive).

pub fn is_active(&self, actor_id: ActorId) -> bool

Returns true if the actor is registered and active.

pub fn get(&self, actor_id: ActorId) -> Option<&ActorRegistration>

Returns the actor registration, if known.

pub fn identity(&self, actor_id: ActorId) -> Option<&str>

Returns the identity string for the actor (used as WAL lease owner).

pub fn active_actors_for_tenant(&self, tenant_id: TenantId) -> Vec<ActorId>

Returns all active actor IDs for the given tenant.

pub fn all_actor_ids(&self) -> impl Iterator<Item = ActorId> + '_

Returns an iterator over all actor IDs (active and deregistered).

Trait Implementations

impl Default for ActorRegistry

fn default() -> ActorRegistry

Returns the “default value” for a type.