Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Holds the daemon’s registered services and routes control-socket envelopes to them by name.

Implementations

impl ServiceRegistry

pub fn new() -> Self

Creates an empty registry.

pub fn register(&mut self, service: Arc<dyn DaemonService>)

Adds a service. Lookups match by DaemonService::name and the first registration wins; a second service sharing a name would be dead code for routing and would double-count in status/menu iteration, so it is rejected with a warning rather than silently kept.

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

Returns the registered service with the given name, if any.

pub fn services(&self) -> &[Arc<dyn DaemonService>]

All registered services, in registration order.

pub async fn dispatch( &self, service: &str, op: &str, payload: Value, ) -> Result<Value>

Routes an operation to the named service, erroring if no such service is registered.

pub fn subscribe( &self, service: &str, op: &str, payload: &Value, ) -> Option<Box<dyn ServiceStream>>

Opens a push subscription on the named service for a streaming op, or None when the service is unknown or does not stream that op — in which case the caller falls back to the normal dispatch request→reply path (#1267).

pub async fn statuses(&self) -> Vec<ServiceStatus>

Collects status from every service, in registration order.

pub async fn shutdown_all(&self)

Gracefully shuts down every service, in registration order.

Trait Implementations

impl Clone for ServiceRegistry

fn clone(&self) -> ServiceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ServiceRegistry

fn default() -> ServiceRegistry

Returns the “default value” for a type.