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
sourceimpl NamespacedKubernetesOrchestrator
impl NamespacedKubernetesOrchestrator
sourcepub(crate) fn list_params(&self) -> ListParams
pub(crate) fn list_params(&self) -> ListParams
Return a ListParams
instance that limits results to the namespace
assigned to this orchestrator.
Trait Implementations
sourceimpl Clone for NamespacedKubernetesOrchestrator
impl Clone for NamespacedKubernetesOrchestrator
sourcefn clone(&self) -> NamespacedKubernetesOrchestrator
fn clone(&self) -> NamespacedKubernetesOrchestrator
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl NamespacedOrchestrator for NamespacedKubernetesOrchestrator
impl NamespacedOrchestrator for NamespacedKubernetesOrchestrator
sourcefn 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,
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.
sourcefn 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,
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.
sourcefn 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,
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. Read more
sourcefn watch_services(&self) -> BoxStream<'static, Result<ServiceEvent, Error>>
fn watch_services(&self) -> BoxStream<'static, Result<ServiceEvent, Error>>
Watch for status changes of all known services.
Auto Trait Implementations
impl !RefUnwindSafe for NamespacedKubernetesOrchestrator
impl Send for NamespacedKubernetesOrchestrator
impl Sync for NamespacedKubernetesOrchestrator
impl Unpin for NamespacedKubernetesOrchestrator
impl !UnwindSafe for NamespacedKubernetesOrchestrator
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more