Struct RateCancelPolicy 

pub struct RateCancelPolicy { /* private fields */ }

Error policy that cancels tasks when failure rate exceeds threshold within time window

This policy tracks failures over a rolling time window and triggers cancellation when the failure rate exceeds the specified threshold. More sophisticated than simple count-based thresholds as it considers the time dimension.

Example

// Cancel if more than 50% of tasks fail within any 60-second window
let (policy, token) = RateCancelPolicy::builder()
    .rate(0.5)
    .window_secs(60)
    .build();

Implementations

impl RateCancelPolicy

pub fn builder() -> RateCancelPolicyBuilder

Create a builder for rate-based cancel policy

Trait Implementations

impl ArcPolicy for RateCancelPolicy

fn new_arc(self) -> Arc<Self>

Create an Arc-wrapped instance of this policy

impl Debug for RateCancelPolicy

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

Formats the value using the given formatter.

impl OnErrorPolicy for RateCancelPolicy

fn create_child(&self) -> Arc<dyn OnErrorPolicy>

Create a child policy for a child tracker

fn create_context(&self) -> Option<Box<dyn Any + Send + 'static>>

Create per-task context state (None if policy is stateless)

fn on_error(&self, error: &Error, context: &mut OnErrorContext) -> ErrorResponse

Handle a task failure and return the desired response

fn allow_continuation(&self, _error: &Error, _context: &OnErrorContext) -> bool

Should continuations be allowed for this error?

fn should_reschedule(&self, _error: &Error, _context: &OnErrorContext) -> bool

Should this continuation be rescheduled through the scheduler?