Struct mz_orchestrator_kubernetes::NamespacedKubernetesOrchestrator

pub(crate) struct NamespacedKubernetesOrchestrator {
    pub(crate) service_api: Api<K8sService>,
    pub(crate) stateful_set_api: Api<StatefulSet>,
    pub(crate) pod_api: Api<Pod>,
    pub(crate) kubernetes_namespace: String,
    pub(crate) namespace: String,
    pub(crate) config: KubernetesOrchestratorConfig,
}

Fields

service_api: Api<K8sService>

stateful_set_api: Api<StatefulSet>

pod_api: Api<Pod>

kubernetes_namespace: String

namespace: String

config: KubernetesOrchestratorConfig

Implementations

impl NamespacedKubernetesOrchestrator

pub(crate) fn list_params(&self) -> ListParams

Return a ListParams instance that limits results to the namespace assigned to this orchestrator.

Trait Implementations

impl Clone for NamespacedKubernetesOrchestrator

fn clone(&self) -> NamespacedKubernetesOrchestrator

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

Lists the identifiers of all known services.

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

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.