Struct mz_orchestrator_kubernetes::NamespacedKubernetesOrchestrator

pub(crate) struct NamespacedKubernetesOrchestrator {
    pub(crate) pod_api: Api<Pod>,
    pub(crate) kubernetes_namespace: String,
    pub(crate) namespace: String,
    pub(crate) config: KubernetesOrchestratorConfig,
    pub(crate) scheduling_config: RwLock<ServiceSchedulingConfig>,
    pub(crate) service_infos: Mutex<BTreeMap<String, ServiceInfo>>,
    pub(crate) command_tx: UnboundedSender<WorkerCommand>,
    pub(crate) _worker: AbortOnDropHandle<()>,
}

Fields

pod_api: Api<Pod>

kubernetes_namespace: String

namespace: String

config: KubernetesOrchestratorConfig

scheduling_config: RwLock<ServiceSchedulingConfig>

service_infos: Mutex<BTreeMap<String, ServiceInfo>>

command_tx: UnboundedSender<WorkerCommand>

_worker: AbortOnDropHandle<()>

Implementations

impl NamespacedKubernetesOrchestrator

pub(crate) fn service_name(&self, id: &str) -> String

pub(crate) fn watch_pod_params(&self) -> Config

Return a watcher::Config instance that limits results to the namespace assigned to this orchestrator.

pub(crate) fn make_label_key(&self, key: &str) -> String

Convert a higher-level label key to the actual one we will give to Kubernetes

pub(crate) fn label_selector_to_k8s( &self, _: MzLabelSelector, ) -> Result<LabelSelectorRequirement, Error>

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

Trait Implementations

impl Debug for NamespacedKubernetesOrchestrator

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

Formats the value using the given formatter.

impl NamespacedOrchestrator for NamespacedKubernetesOrchestrator

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 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, _: ServiceConfig, ) -> Result<Box<dyn Service>, Error>

Ensures that a service with the given configuration is running.

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

Watch for status changes of all known services.

fn update_scheduling_config(&self, config: ServiceSchedulingConfig)