pub(crate) struct OrchestratorWorker {
pub(crate) metrics_api: Api<PodMetrics>,
pub(crate) custom_metrics_api: Api<MetricValueList>,
pub(crate) service_api: Api<Service>,
pub(crate) stateful_set_api: Api<StatefulSet>,
pub(crate) pod_api: Api<Pod>,
pub(crate) command_rx: UnboundedReceiver<WorkerCommand>,
}
Expand description
A task executing blocking work for a NamespacedKubernetesOrchestrator
in the background.
This type exists to enable making NamespacedKubernetesOrchestrator::ensure_service
and
NamespacedKubernetesOrchestrator::drop_service
non-blocking, allowing invocation of these
methods in latency-sensitive contexts.
Note that, apart from ensure_service
and drop_service
, this worker also handles blocking
orchestrator calls that query service state (such as list_services
). These need to be
sequenced through the worker loop to ensure they linearize as expected. For example, we want to
ensure that a list_services
result contains exactly those services that were previously
created with ensure_service
and not yet dropped with drop_service
.
Fields§
§metrics_api: Api<PodMetrics>
§custom_metrics_api: Api<MetricValueList>
§service_api: Api<Service>
§stateful_set_api: Api<StatefulSet>
§pod_api: Api<Pod>
§command_rx: UnboundedReceiver<WorkerCommand>
Implementations§
source§impl OrchestratorWorker
impl OrchestratorWorker
pub(crate) fn spawn(self, name: String) -> AbortOnDropHandle<()>
pub(crate) async fn run(self)
sourcepub(crate) async fn handle_command(&mut self, cmd: WorkerCommand)
pub(crate) async fn handle_command(&mut self, cmd: WorkerCommand)
Handle a worker command.
If handling the command fails, it is automatically retried. All command handlers return
K8sError
, so we can reasonably assume that a failure is caused by issues communicating
with the K8S server and that retrying resolves them eventually.
pub(crate) async fn fetch_service_metrics( &self, name: &str, info: &ServiceInfo, ) -> Vec<ServiceProcessMetrics>
pub(crate) async fn ensure_service( &self, desc: &ServiceDescription, ) -> Result<(), K8sError>
pub(crate) async fn drop_service(&self, name: &str) -> Result<(), K8sError>
pub(crate) async fn list_services( &self, namespace: &str, ) -> Result<Vec<String>, K8sError>
Auto Trait Implementations§
impl Freeze for OrchestratorWorker
impl !RefUnwindSafe for OrchestratorWorker
impl Send for OrchestratorWorker
impl Sync for OrchestratorWorker
impl Unpin for OrchestratorWorker
impl !UnwindSafe for OrchestratorWorker
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
std::ops::AddAssign
, for types that do not implement AddAssign
.