Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Registry of system services with lifecycle management.

Uses DashMap for concurrent access from multiple kernel subsystems. Maintains two maps:

• services: SystemService trait object implementations (existing)
• entries: ServiceEntry metadata for service identity (D1, K2.1)

A service can have metadata before it has a running implementation (useful for external services), and vice versa.

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create a new, empty service registry.

pub fn register( &self, service: Arc<dyn SystemService>, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register a service.

Returns an error if a service with the same name is already registered.

pub fn unregister(&self, name: &str) -> Option<Arc<dyn SystemService>>

Unregister a service by name.

pub fn get(&self, name: &str) -> Option<Arc<dyn SystemService>>

Get a service by name.

pub fn list(&self) -> Vec<(String, ServiceType)>

List all registered services with their types.

pub async fn start_all(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Start all registered services.

Individual service failures are logged as warnings but do not prevent other services from starting.

pub async fn stop_all(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Stop all registered services.

Individual service failures are logged as warnings.

pub fn snapshot(&self) -> Vec<(String, Arc<dyn SystemService>)>

Return a snapshot of all services as a Vec.

This copies all (name, Arc<dyn SystemService>) pairs out of the DashMap, so the returned collection owns no DashMap refs and is safe to hold across await points and send across threads.

pub async fn health_all(&self) -> Vec<(String, HealthStatus)>

Run health checks on all registered services.

pub fn register_entry( &self, entry: ServiceEntry, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register a service entry (metadata, not a running implementation).

Returns an error if an entry with the same name already exists.

pub fn get_entry(&self, name: &str) -> Option<ServiceEntry>

Get a service entry by name.

pub fn resolve_target(&self, name: &str) -> Option<Pid>

Resolve a service name to its owning agent PID.

Returns None if the service is not registered or has no owner_pid (e.g. external services).

pub fn list_entries(&self) -> Vec<ServiceEntry>

List all registered service entries.

pub fn unregister_entry(&self, name: &str) -> Option<ServiceEntry>

Remove a service entry by name.

pub fn register_with_tree( &self, service: Arc<dyn SystemService>, tree_manager: &TreeManager, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register a service and create a resource tree node + chain event.

When the exochain feature is enabled and a tree manager is provided, creates a node at /kernel/services/{name} in the resource tree and appends a corresponding chain event via TreeManager.

pub fn len(&self) -> usize

Get the number of registered services.

pub fn is_empty(&self) -> bool

Check whether the registry is empty.

pub fn register_with_contract( &self, service: Arc<dyn SystemService>, methods: Vec<String>, chain: &ChainManager, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register a service and automatically create a chain-anchored contract (C3).

This is the recommended registration path for K4+ services that want immutable API contracts stored on the ExoChain. It combines service registration, contract creation, and chain logging in one call.

pub fn register_contract( &self, contract: &ServiceContract, chain: &ChainManager, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register a service contract and log it to the chain (K2 C3, K4 G2).

A service contract is a versioned interface declaration that is anchored in the ExoChain for immutability. Once a contract version is registered, it cannot be changed — only superseded by a new version.

Trait Implementations

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.

impl Registry for ServiceRegistry

type Value = Arc<dyn SystemService>

The value returned by get.

fn get(&self, key: &str) -> Option<Self::Value>

Look up a value by its string key.

fn list_keys(&self) -> Vec<String>

Return all keys currently in the registry.

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

Check whether key is present.

fn count(&self) -> usize

Number of entries in the registry.

fn is_empty(&self) -> bool

Whether the registry is empty.