Struct StateRegistry 

pub struct StateRegistry { /* private fields */ }

Registry of all distributed state types on this node.

Stores type-erased AnyStateShard entries keyed by state name. Provides lookup (with typed downcasting) and cluster-event broadcasting.

Implementations

impl StateRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register<S: AnyStateShard>( &mut self, shard: S, ) -> Result<(), RegistryError>

Register a state shard.

The type parameter S must match the concrete type of the shard. The TypeId is derived from S for later typed lookups via lookup_typed.

Returns Err(RegistryError::DuplicateName) if a shard with the same name is already registered.

pub fn lookup(&self, name: &str) -> Result<&dyn AnyStateShard, RegistryError>

Look up a shard by name (type-erased).

pub fn lookup_typed<T: AnyStateShard + 'static>( &self, name: &str, ) -> Result<&T, RegistryError>

Look up a shard by name and downcast to a concrete type T.

Returns Err(TypeMismatch) if the registered TypeId doesn’t match TypeId::of::<T>().

pub fn broadcast_node_joined(&self, node_id: NodeId)

Broadcast NodeJoined to all registered shards.

pub fn broadcast_node_left(&self, node_id: NodeId)

Broadcast NodeLeft to all registered shards.

pub fn len(&self) -> usize

Number of registered state types.

pub fn is_empty(&self) -> bool

Whether the registry is empty.

pub fn state_names(&self) -> impl Iterator<Item = &str>

Iterate over all registered state names.

Trait Implementations

impl Default for StateRegistry

fn default() -> Self

Returns the “default value” for a type.