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<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    id: &'life1 str,
    service_config: ServiceConfig<'life2>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn Service>, Error>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Ensures that a service with the given configuration is running.

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

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.