Struct mz_orchestrator_kubernetes::KubernetesOrchestrator

pub struct KubernetesOrchestrator {
    pub(crate) client: Client,
    pub(crate) kubernetes_namespace: String,
    pub(crate) config: KubernetesOrchestratorConfig,
    pub(crate) secret_api: Api<Secret>,
    pub(crate) vpc_endpoint_api: Api<VpcEndpoint>,
    pub(crate) namespaces: Mutex<BTreeMap<String, Arc<dyn NamespacedOrchestrator>>>,
    pub(crate) resource_reader: Arc<KubernetesResourceReader>,
}

An orchestrator backed by Kubernetes.

Fields

client: Client

kubernetes_namespace: String

config: KubernetesOrchestratorConfig

secret_api: Api<Secret>

vpc_endpoint_api: Api<VpcEndpoint>

namespaces: Mutex<BTreeMap<String, Arc<dyn NamespacedOrchestrator>>>

resource_reader: Arc<KubernetesResourceReader>

Implementations

impl KubernetesOrchestrator

pub async fn new( config: KubernetesOrchestratorConfig, ) -> Result<KubernetesOrchestrator, Error>

Creates a new Kubernetes orchestrator from the provided configuration.

Trait Implementations

impl CloudResourceController for KubernetesOrchestrator

fn ensure_vpc_endpoint<'life0, 'async_trait>( &'life0 self, id: CatalogItemId, config: VpcEndpointConfig, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Creates or updates the specified VpcEndpoint Kubernetes object.

fn delete_vpc_endpoint<'life0, 'async_trait>( &'life0 self, id: CatalogItemId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Deletes the specified VpcEndpoint Kubernetes object.

fn list_vpc_endpoints<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BTreeMap<CatalogItemId, VpcEndpointStatus>, Error>> + Send + 'async_trait>>

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

Lists existing VpcEndpoint Kubernetes objects.

fn watch_vpc_endpoints<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = BoxStream<'static, VpcEndpointEvent>> + Send + 'async_trait>>

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

Lists existing VpcEndpoint Kubernetes objects.

fn reader(&self) -> Arc<dyn CloudResourceReader>

Returns a reader for the resources managed by this controller.

impl CloudResourceReader for KubernetesOrchestrator

fn read<'life0, 'async_trait>( &'life0 self, id: CatalogItemId, ) -> Pin<Box<dyn Future<Output = Result<VpcEndpointStatus, Error>> + Send + 'async_trait>>

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

Reads the specified VpcEndpoint Kubernetes object.

impl Debug for KubernetesOrchestrator

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

Formats the value using the given formatter.

impl Orchestrator for KubernetesOrchestrator

fn namespace(&self, namespace: &str) -> Arc<dyn NamespacedOrchestrator>

Enter a namespace in the orchestrator.

impl SecretsController for KubernetesOrchestrator

fn ensure<'life0, 'life1, 'async_trait>( &'life0 self, id: CatalogItemId, contents: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Creates or updates the specified secret with the specified binary contents.

fn delete<'life0, 'async_trait>( &'life0 self, id: CatalogItemId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Deletes the specified secret.

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

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

Lists known secrets. Unrecognized secret objects do not produce an error and are ignored.

fn reader(&self) -> Arc<dyn SecretsReader>

Returns a reader for the secrets managed by this controller.