Struct AttemptRunner 

pub struct AttemptRunner<H, T = SystemAttemptTimer> { /* private fields */ }

Runs single-attempt executions by composing handler, timeout, and retry input derivation.

Implementations

impl<H> AttemptRunner<H, SystemAttemptTimer>

where H: ExecutorHandler,

pub fn new(handler: H) -> Self

Creates an attempt runner using the default system timer.

impl<H, T> AttemptRunner<H, T>

where H: ExecutorHandler, T: AttemptTimer,

pub fn with_timer(handler: H, timer: T) -> Self

Creates an attempt runner with an explicit timer implementation.

pub fn with_timer_and_metrics( handler: H, timer: T, timeout_metrics: TimeoutCooperationMetrics, ) -> Self

Creates an attempt runner with explicit timer and timeout metric sink.

pub fn with_timer_metrics_and_cadence_policy( handler: H, timer: T, timeout_metrics: TimeoutCooperationMetrics, timeout_cadence_policy: TimeoutCadencePolicy, ) -> Self

Creates an attempt runner with explicit timer, metric sink, and cadence policy.

pub fn timeout_metrics(&self) -> &TimeoutCooperationMetrics

Returns the timeout cooperation metric sink used by this runner.

pub fn timeout_cadence_policy(&self) -> TimeoutCadencePolicy

Returns the timeout cadence policy used by this runner.

pub fn run_attempt(&self, request: ExecutorRequest) -> AttemptOutcomeRecord

Executes exactly one attempt and returns one terminal attempt outcome record.

Trait Implementations

impl<H: Clone, T: Clone> Clone for AttemptRunner<H, T>

fn clone(&self) -> AttemptRunner<H, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: Debug, T: Debug> Debug for AttemptRunner<H, T>

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

Formats the value using the given formatter.