Struct BreakerSampler 

pub struct BreakerSampler<S> { /* private fields */ }

Sampler wrapper that refuses traffic while the breaker is open.

Implementations

impl<S> BreakerSampler<S>

pub fn new( inner: Arc<S>, breaker: Arc<CircuitBreaker>, endpoint: impl Into<String>, ) -> BreakerSampler<S>

Wrap inner with a shared breaker.

pub fn endpoint(&self) -> &str

Endpoint label.

pub fn breaker(&self) -> &Arc<CircuitBreaker>

Shared breaker.

Trait Implementations

impl<S> Clone for BreakerSampler<S>

where S: Clone,

fn clone(&self) -> BreakerSampler<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S> Debug for BreakerSampler<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S> LlmSampler for BreakerSampler<S>

where S: LlmSampler + 'static,

fn sample<'life0, 'async_trait>( &'life0 self, request: SampleRequest, ) -> Pin<Box<dyn Future<Output = Result<SampleResponse, MachiError>> + Send + 'async_trait>>

where 'life0: 'async_trait, BreakerSampler<S>: 'async_trait,

Perform one non-streaming sample.

fn sample_stream<'life0, 'async_trait>( &'life0 self, request: SampleRequest, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = SampleEvent> + Send>>, MachiError>> + Send + 'async_trait>>

where 'life0: 'async_trait, BreakerSampler<S>: 'async_trait,

Streaming sample. Default: call Self::sample and emit a single SampleEvent::Completed (plus usage when non-zero).