Struct ServiceManager 

pub(crate) struct ServiceManager<P: ProcessSpawner> {
    pub(crate) status: StatusHandle,
    pub(crate) cmd_rx: Receiver<Command>,
    pub(crate) spawner: P,
    pub(crate) poll_interval: Interval,
    pub(crate) system_active: bool,
    pub(crate) system_dependencies: SystemDependency,
    pub(crate) services: Vec<ServiceWithState>,
    pub(crate) services_pending_removal: Vec<ServiceWithState>,
}

Fields

status: StatusHandle

cmd_rx: Receiver<Command>

spawner: P

poll_interval: Interval

system_active: bool

system_dependencies: SystemDependency

services: Vec<ServiceWithState>

Invariant: this list is always sorted in ascending order.

services_pending_removal: Vec<ServiceWithState>

Contains services that were previously active and should be stopped and removed.

Implementations

impl<P: ProcessSpawner> ServiceManager<P>

pub(crate) async fn spawn( event_tx: EventSender, spawner: P, service_dirs: Vec<PathBuf>, ) -> Result<ServiceManagerHandle>

pub(crate) async fn new( status: StatusHandle, cmd_rx: Receiver<Command>, spawner: P, service_dirs: Vec<PathBuf>, ) -> Self

pub(crate) async fn run(self)

pub(crate) async fn poll(&mut self)

Applies the desired state to all services once.

See the crate-level documentation for more information.

pub(crate) async fn remove_pending(&mut self)

pub(crate) fn replace_services(&mut self, definitions: Vec<ServiceDefinition>)

Replaces the list of active services.

The new services must be sorted by id in ascending order and should not contain duplicate service IDs.