Struct Registry 

pub struct Registry { /* private fields */ }

Registry struct that manages both shared and unique objects.

Examples

use dynamo_runtime::pipeline::registry::Registry;

let mut registry = Registry::new();

// Insert and retrieve shared objects
registry.insert_shared("shared1", 42);
assert_eq!(*registry.get_shared::<i32>("shared1").unwrap(), 42);

// Insert and take unique objects
registry.insert_unique("unique1", "Hello".to_string());
assert_eq!(registry.take_unique::<String>("unique1").unwrap(), "Hello");

// Taking the same unique again should fail since it's not cloneable
assert!(registry.take_unique::<String>("unique1").is_err());

// Insert and clone unique objects
registry.insert_unique("unique2", "World".to_string());
assert_eq!(registry.clone_unique::<String>("unique2").unwrap(), "World");

// Taking the same cloned unique should is ok
assert!(registry.take_unique::<String>("unique2").is_ok());

Implementations

impl Registry

pub fn new() -> Self

Create a new empty registry.

pub fn contains_shared(&self, key: &str) -> bool

Check if a shared object exists in the registry by key.

pub fn insert_shared<K: ToString, U: Send + Sync + 'static>( &mut self, key: K, value: U, )

Insert a shared object into the registry with a specific key.

pub fn get_shared<V: Send + Sync + 'static>( &self, key: &str, ) -> Result<Arc<V>, String>

Retrieve a shared object from the registry by key and type.

pub fn contains_unique(&self, key: &str) -> bool

Check if a unique object exists in the registry by key.

pub fn insert_unique<K: ToString, U: Send + Sync + 'static>( &mut self, key: K, value: U, )

Insert a unique object into the registry with a specific key.

pub fn take_unique<V: Send + Sync + 'static>( &mut self, key: &str, ) -> Result<V, String>

Take a unique object from the registry by key and type, removing it from the registry.

pub fn clone_unique<V: Clone + Send + Sync + 'static>( &self, key: &str, ) -> Result<V, String>

Clone a unique object from the registry if it implements Clone.

Trait Implementations

impl Debug for Registry

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

Formats the value using the given formatter.

impl Default for Registry

fn default() -> Registry

Returns the “default value” for a type.