pub struct OperatorObservability { /* private fields */ }Implementations§
Source§impl OperatorObservability
impl OperatorObservability
pub fn from_env() -> Result<Self>
pub fn with_logger_provider(self, provider: Option<SdkLoggerProvider>) -> Self
pub fn mark_ready(&self)
pub fn mark_not_ready(&self)
pub fn start_reconcile(&self) -> ReconcileGuard
pub fn record_database_connection_failure(&self)
pub fn record_policy_conflict(&self)
pub fn record_lock_contention(&self)
pub fn record_plan_result(&self, result: &str)
pub fn record_planned_changes(&self, changes: usize)
pub fn record_invalid_spec(&self)
Sourcepub fn record_deprecated_approval_unset(&self, inferred: &str)
pub fn record_deprecated_approval_unset(&self, inferred: &str)
Count a reconcile that relied on the deprecated spec.approval
inference, so the remaining exposure is alertable fleet-wide rather than
only visible per object.
pub fn record_inspection(&self, stats: &InspectionStats)
pub fn record_apply_result(&self, result: &str)
pub fn record_apply_statements(&self, statements: usize)
pub fn record_ephemeral_transition(&self, phase: &str, reason: &str)
pub fn record_ephemeral_retained_memberships(&self, count: usize)
pub fn record_ephemeral_expiry_lag(&self, lag: Duration)
pub fn record_ephemeral_role_retirement_blocked(&self)
pub fn record_ephemeral_relevant_requests( &self, lookup: &'static str, count: usize, )
pub fn start_ephemeral_reconcile( &self, kind: &'static str, cached_requests: usize, ) -> EphemeralReconcileGuard
pub fn shutdown(&self) -> Result<()>
Trait Implementations§
Source§impl Clone for OperatorObservability
impl Clone for OperatorObservability
Source§fn clone(&self) -> OperatorObservability
fn clone(&self) -> OperatorObservability
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for OperatorObservability
impl !UnwindSafe for OperatorObservability
impl Freeze for OperatorObservability
impl Send for OperatorObservability
impl Sync for OperatorObservability
impl Unpin for OperatorObservability
impl UnsafeUnpin for OperatorObservability
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> ⓘ
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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>
Wrap the input message
T in a tonic::RequestSource§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more