pub struct ResilienceObservability { /* private fields */ }Expand description
Observability service for resilience operations
Implementations§
Source§impl ResilienceObservability
impl ResilienceObservability
Sourcepub fn with_components(
metrics_collector: Arc<dyn MetricsCollector>,
tracer: Arc<dyn ResilienceTracer>,
) -> Self
pub fn with_components( metrics_collector: Arc<dyn MetricsCollector>, tracer: Arc<dyn ResilienceTracer>, ) -> Self
Create with custom collector and tracer
Sourcepub fn record_operation_start(
&self,
operation_id: &str,
policy: &ResiliencePolicy,
)
pub fn record_operation_start( &self, operation_id: &str, policy: &ResiliencePolicy, )
Record the start of a resilience operation
Sourcepub fn record_operation_complete(
&self,
operation_id: &str,
policy: &ResiliencePolicy,
duration: Duration,
result: &Result<(), ResilienceOrchestrationError>,
)
pub fn record_operation_complete( &self, operation_id: &str, policy: &ResiliencePolicy, duration: Duration, result: &Result<(), ResilienceOrchestrationError>, )
Record the completion of a resilience operation
Sourcepub fn record_operation_error(
&self,
operation_id: &str,
error: &ResilienceOrchestrationError,
)
pub fn record_operation_error( &self, operation_id: &str, error: &ResilienceOrchestrationError, )
Record resilience-specific errors
Sourcepub fn record_circuit_breaker_state_change(
&self,
circuit_breaker_id: &str,
old_state: CircuitBreakerState,
new_state: CircuitBreakerState,
)
pub fn record_circuit_breaker_state_change( &self, circuit_breaker_id: &str, old_state: CircuitBreakerState, new_state: CircuitBreakerState, )
Record circuit breaker state changes
Sourcepub fn health_status(&self) -> ResilienceHealthStatus
pub fn health_status(&self) -> ResilienceHealthStatus
Get current health status
Sourcepub fn export_prometheus_metrics(&self) -> String
pub fn export_prometheus_metrics(&self) -> String
Export metrics in Prometheus format
Trait Implementations§
Source§impl Clone for ResilienceObservability
impl Clone for ResilienceObservability
Source§fn clone(&self) -> ResilienceObservability
fn clone(&self) -> ResilienceObservability
Returns a duplicate of the value. Read more
1.0.0 · 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 Freeze for ResilienceObservability
impl !RefUnwindSafe for ResilienceObservability
impl Send for ResilienceObservability
impl Sync for ResilienceObservability
impl Unpin for ResilienceObservability
impl UnsafeUnpin for ResilienceObservability
impl !UnwindSafe for ResilienceObservability
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> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Convert
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Convert
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSync for T
impl<T> DowncastSync for 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> 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> 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> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<R, P> ReadPrimitive<R> for P
impl<R, P> ReadPrimitive<R> for P
Source§fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
Read this value from the supplied reader. Same as
ReadEndian::read_from_little_endian().