Struct mz_orchestrator_process::NamespacedProcessOrchestrator

pub(crate) struct NamespacedProcessOrchestrator {
    pub(crate) config: Arc<NamespacedProcessOrchestratorConfig>,
    pub(crate) services: Arc<Mutex<BTreeMap<String, Vec<ProcessState>>>>,
    pub(crate) service_event_rx: Receiver<ServiceEvent>,
    pub(crate) command_tx: UnboundedSender<WorkerCommand>,
    pub(crate) _worker: AbortOnDropHandle<()>,
}

Fields

config: Arc<NamespacedProcessOrchestratorConfig>

services: Arc<Mutex<BTreeMap<String, Vec<ProcessState>>>>

service_event_rx: Receiver<ServiceEvent>

command_tx: UnboundedSender<WorkerCommand>

_worker: AbortOnDropHandle<()>

Implementations

impl NamespacedProcessOrchestrator

pub(crate) fn send_command(&self, cmd: WorkerCommand)

Trait Implementations

impl Debug for NamespacedProcessOrchestrator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl NamespacedOrchestrator for NamespacedProcessOrchestrator

fn ensure_service( &self, id: &str, config: ServiceConfig, ) -> Result<Box<dyn Service>, Error>

Ensures that a service with the given configuration is running.

fn drop_service(&self, id: &str) -> Result<(), Error>

Drops the identified service, if it exists.

fn list_services<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists the identifiers of all known services.

fn watch_services(&self) -> BoxStream<'static, Result<ServiceEvent, Error>>

Watch for status changes of all known services.

fn fetch_service_metrics<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceProcessMetrics>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets resource usage metrics for all processes associated with a service.

fn update_scheduling_config(&self, _config: ServiceSchedulingConfig)