Struct ThresholdCancelPolicy 

pub struct ThresholdCancelPolicy { /* private fields */ }

Error policy that cancels tasks after a threshold number of failures

This policy tracks the number of failed tasks and triggers cancellation when the failure count exceeds the specified threshold. Useful for preventing cascading failures in distributed systems.

Example

// Cancel after 5 failures
let policy = ThresholdCancelPolicy::with_threshold(5);

Implementations

impl ThresholdCancelPolicy

pub fn with_threshold(max_failures: usize) -> Arc<Self>

Create a new threshold cancel policy with specified failure threshold, returning Arc and token

Arguments

• max_failures - Maximum number of failures before cancellation

pub fn failure_count(&self) -> u64

Get the current failure count

pub fn reset_failure_count(&self)

Reset the failure count to zero

This is primarily useful for testing scenarios where you want to reset the policy state between test cases.

Trait Implementations

impl ArcPolicy for ThresholdCancelPolicy

fn new_arc(self) -> Arc<Self>

Create an Arc-wrapped instance of this policy

impl Debug for ThresholdCancelPolicy

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

Formats the value using the given formatter.

impl OnErrorPolicy for ThresholdCancelPolicy

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?