Struct mz_orchestrator_tracing::NamespacedTracingOrchestrator

pub(crate) struct NamespacedTracingOrchestrator {
    pub(crate) namespace: String,
    pub(crate) inner: Arc<dyn NamespacedOrchestrator>,
    pub(crate) tracing_args: TracingCliArgs,
}

Fields

namespace: String

inner: Arc<dyn NamespacedOrchestrator>

tracing_args: TracingCliArgs

Trait Implementations

impl Debug for NamespacedTracingOrchestrator

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

Formats the value using the given formatter.

impl NamespacedOrchestrator for NamespacedTracingOrchestrator

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 ensure_service( &self, id: &str, service_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 update_scheduling_config(&self, config: ServiceSchedulingConfig)