Struct Registry 

pub struct Registry<T> { /* private fields */ }

A thread-safe registry for named components.

Provides concurrent read access with exclusive write access, suitable for storing configuration-driven components that are read frequently but updated rarely (e.g., during config reload).

Implementations

impl<T> Registry<T>

pub fn new() -> Self

Create a new empty registry.

pub fn with_capacity(capacity: usize) -> Self

Create a registry with pre-allocated capacity.

pub fn from_map(map: HashMap<String, Arc<T>>) -> Self

Create a registry from an existing HashMap.

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

Get a component by ID.

pub async fn contains(&self, id: &str) -> bool

Check if a component exists.

pub async fn insert( &self, id: impl Into<String>, item: Arc<T>, ) -> Option<Arc<T>>

Insert a component, returning the previous value if any.

pub async fn remove(&self, id: &str) -> Option<Arc<T>>

Remove a component by ID.

pub async fn keys(&self) -> Vec<String>

Get all component IDs.

pub async fn len(&self) -> usize

Get the number of components.

pub async fn is_empty(&self) -> bool

Check if the registry is empty.

pub async fn clear(&self)

Clear all components.

pub async fn replace( &self, new_items: HashMap<String, Arc<T>>, ) -> HashMap<String, Arc<T>>

Replace all items atomically, returning the old map.

pub async fn snapshot(&self) -> HashMap<String, Arc<T>>

Get a snapshot of all items.

pub async fn with_read<F, R>(&self, f: F) -> R

where F: FnOnce(&HashMap<String, Arc<T>>) -> R,

Execute a function while holding the read lock.

Useful for operations that need to access multiple items atomically.

pub async fn with_write<F, R>(&self, f: F) -> R

where F: FnOnce(&mut HashMap<String, Arc<T>>) -> R,

Execute a function while holding the write lock.

Useful for operations that need to modify multiple items atomically.

Trait Implementations

impl<T> Clone for Registry<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Registry<T>

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

Formats the value using the given formatter.

impl<T> Default for Registry<T>

fn default() -> Self

Returns the “default value” for a type.