Struct DaemonRegistry 

pub struct DaemonRegistry { /* private fields */ }

Implementations

impl DaemonRegistry

pub fn new() -> Self

Create an empty registry. Missing starters are treated as unwired optional subsystems by daemon::run.

pub fn register_gateway( &mut self, starter: Box<dyn Fn(String, u16, Config, Option<Sender<Value>>, Option<GatewayReloadControls>, Option<Arc<TuiRegistry>>, Option<GatewayReadinessReporter>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn register_channels( &mut self, starter: Box<dyn Fn(Config, CancellationToken) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn register_socket( &mut self, starter: Box<dyn Fn(Arc<RpcContext>, CancellationToken, Arc<AtomicUsize>, Option<SocketReadinessReporter>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn register_wss( &mut self, starter: Box<dyn Fn(Arc<RpcContext>, CancellationToken, Arc<AtomicUsize>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn register_relay( &mut self, starter: Box<dyn Fn(Arc<RpcContext>, CancellationToken, Arc<AtomicUsize>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn register_enroll( &mut self, starter: Box<dyn Fn(Arc<RpcContext>, CancellationToken, Arc<AtomicUsize>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

Register the certificate enrollment endpoint (the bootstrap surface a certless client reaches for its first cert). Supervised like the WSS listener; the starter parks when [enroll] is disabled.

pub fn register_mqtt( &mut self, starter: Box<dyn Fn(MqttConfig) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync>, ) -> &mut Self

pub fn set_sop_engine( &mut self, sop_engine: Option<Arc<Mutex<SopEngine>>>, sop_audit: Option<Arc<SopAuditLogger>>, ) -> &mut Self

Set the shared SOP engine for this daemon iteration.

Trait Implementations

impl Default for DaemonRegistry

fn default() -> DaemonRegistry

Returns the “default value” for a type.