Struct ComponentRegistry 

pub struct ComponentRegistry { /* private fields */ }

The central component registry.

Cloning a ComponentRegistry is cheap: it is backed by Arc-shared inner state. All clones observe the same set of registered components.

Implementations

impl ComponentRegistry

pub fn new() -> Self

Construct an empty registry with a fresh shutdown token.

pub fn with_shutdown(shutdown: ShutdownToken) -> Self

Construct a registry that hands shutdown to every component on init. Used by the future ManagedRuntime to wire a single root shutdown into every component.

pub fn shutdown(&self) -> ShutdownToken

Borrow the root shutdown token.

pub fn register_factory( &self, descriptor: ComponentDescriptor, factory: Box<dyn ComponentFactory>, ) -> Result<(), RegistryError>

Register a factory. Invalidates the cached topological order.

Errors

• RegistryError::AlreadyRegistered if the name is taken.

pub fn register_typed<C: Component>( &self, instance_name: impl Into<String>, config: Value, ) -> Result<(), RegistryError>

Register a typed component using its Component::NAME constant and Component::depends_on metadata.

pub fn unregister( &self, name: &str, ) -> Result<ComponentDescriptor, RegistryError>

Unregister a component. Returns the previous descriptor, or RegistryError::NotFound if the name was not registered.

pub fn len(&self) -> usize

Number of registered components.

pub fn is_empty(&self) -> bool

Returns true if no components are registered.

pub fn names(&self) -> Vec<String>

Returns the user-assigned names of all registered components, in topological init order.

pub fn get<C: Component>(&self, name: &str) -> Result<Arc<C>, RegistryError>

Look up an initialized component by name, downcasting to a concrete Arc<C>.

Errors

• RegistryError::NotFound if the name is not registered.
• RegistryError::TypeMismatch if the stored instance is not of type C.
• RegistryError::AlreadyInitialized is not raised here; a registered component without an instance simply returns NotFound.

pub fn is_initialized(&self, name: &str) -> bool

Returns true if a component with the given name has been successfully initialized.

pub fn state_of(&self, name: &str) -> Option<ComponentState>

Snapshot of the current state of a component, or None if the name is not registered.

pub async fn init_all(&self) -> Result<(), RegistryError>

Initialize all registered components in topological order.

On error from any single component, the registry records the failure and continues with components that do not depend on the failed one. The returned error is the first error encountered (the rest are recorded in ComponentState::Failed).

After a successful init_all, subsequent init_all calls are no-ops for already-initialized components. To re-init, unregister the component and re-register it.

pub async fn start_all(&self) -> Result<(), RegistryError>

Start all initialized components in topo order. Components that are not in ComponentState::Initialized (e.g. failed, already running) are skipped.

pub async fn stop_all(&self) -> Result<(), RegistryError>

Stop all running components in reverse topo order. Continues even on per-component failure so a stuck component does not prevent the rest of the system from draining.

pub async fn replace_instance( &self, name: &str, new_instance: Box<dyn AnyComponent>, ) -> Result<Arc<dyn AnyComponent>, RegistryError>

Atomically replace a running component with a new instance, following the drain-aware hot-swap protocol.

The protocol proceeds in five steps:

1. Verify the named component is in ComponentState::Running.
2. Call AnyComponent::pre_replace on the old instance, giving it a chance to reject new traffic or flush buffers.
3. Call AnyComponent::start on the new instance. If this fails, the old instance remains in place.
4. Swap the instance in the registry map. Existing Arc clones held by other tasks remain valid and keep the old instance alive until they are dropped (natural drain).
5. Call AnyComponent::post_replace on the old instance (best-effort; errors are reported but do not roll back).

Returns the old AnyComponent so the caller may await explicit drain or call stop when appropriate.

Errors

• RegistryError::NotFound if no component with name exists.
• RegistryError::Reload if the component is not in Running state, or if pre_replace / start fails.

pub async fn health(&self) -> HashMap<String, HealthStatus>

Aggregate health of every initialized component. Calls AnyComponent::health for each in topo order and collects the results.

pub fn recompute_topo(&self) -> Result<Vec<String>, RegistryError>

Recompute the topological init order from the registered descriptors. Caches the result until the next registration.

Trait Implementations

impl Default for ComponentRegistry

fn default() -> Self

Returns the “default value” for a type.