Struct CasBuilder 

pub struct CasBuilder<T, E = BoxError> { /* private fields */ }

Builder for CasExecutor.

Implementations

impl<T, E> CasBuilder<T, E>

pub fn new() -> Self

Creates a builder with default retry options.

Returns

A CasBuilder using RetryOptions::default.

pub fn options(self, options: RetryOptions) -> Self

Replaces builder settings from an existing retry option snapshot.

Parameters

• options: Retry option snapshot to install.

Returns

The updated builder.

pub fn max_attempts(self, max_attempts: u32) -> Self

Sets the maximum total attempts.

Parameters

• max_attempts: Maximum attempts, including the initial attempt.

Returns

The updated builder.

pub fn max_retries(self, max_retries: u32) -> Self

Sets the maximum retries after the initial attempt.

Parameters

• max_retries: Maximum retries after the first attempt.

Returns

The updated builder.

pub fn max_operation_elapsed( self, max_operation_elapsed: Option<Duration>, ) -> Self

Sets the maximum cumulative user operation elapsed-time budget.

Parameters

• max_operation_elapsed: Optional cumulative user operation time budget.

Returns

The updated builder.

pub fn max_total_elapsed(self, max_total_elapsed: Option<Duration>) -> Self

Sets the maximum monotonic elapsed-time budget for the whole retry flow.

Parameters

• max_total_elapsed: Optional total retry-flow time budget.

Returns

The updated builder.

pub fn delay(self, delay: RetryDelay) -> Self

Sets the base retry delay strategy.

Parameters

• delay: Delay strategy used between failed attempts.

Returns

The updated builder.

pub fn no_delay(self) -> Self

Uses immediate retries with no sleep.

Returns

The updated builder.

pub fn fixed_delay(self, delay: Duration) -> Self

Uses one fixed retry delay.

Parameters

• delay: Delay slept before each retry.

Returns

The updated builder.

pub fn random_delay(self, min: Duration, max: Duration) -> Self

Uses one random retry delay range.

Parameters

• min: Inclusive minimum delay.
• max: Inclusive maximum delay.

Returns

The updated builder.

pub fn exponential_backoff(self, initial: Duration, max: Duration) -> Self

Uses exponential backoff with multiplier 2.0.

Parameters

• initial: Initial retry delay.
• max: Maximum retry delay.

Returns

The updated builder.

pub fn exponential_backoff_with_multiplier( self, initial: Duration, max: Duration, multiplier: f64, ) -> Self

Uses exponential backoff with a custom multiplier.

Parameters

• initial: Initial retry delay.
• max: Maximum retry delay.
• multiplier: Multiplier applied after each failed attempt.

Returns

The updated builder.

pub fn jitter(self, jitter: RetryJitter) -> Self

Sets the jitter strategy.

Parameters

• jitter: Jitter strategy applied to retry delays.

Returns

The updated builder.

pub fn jitter_factor(self, factor: f64) -> Self

Sets relative jitter by factor.

Parameters

• factor: Relative jitter factor in [0.0, 1.0].

Returns

The updated builder.

pub fn attempt_timeout(self, attempt_timeout: Option<Duration>) -> Self

Sets the async per-attempt timeout.

Parameters

• attempt_timeout: Timeout applied to each async CAS attempt.

Returns

The updated builder.

pub fn retry_on_timeout(self) -> Self

Retries attempts that exceed the configured timeout.

Returns

The updated builder.

pub fn abort_on_timeout(self) -> Self

Aborts the CAS flow when one attempt exceeds the timeout.

Returns

The updated builder.

pub fn strategy(self, strategy: CasStrategy) -> Self

Applies a built-in CAS strategy to this builder.

Parameters

• strategy: Strategy profile to install.

Returns

The updated builder.

pub fn observability(self, observability: CasObservabilityConfig) -> Self

Installs observability configuration.

Parameters

• observability: Observability settings to use.

Returns

The updated builder.

pub fn alert_on_contention(self, thresholds: ContentionThresholds) -> Self

Enables contention alerting with the supplied thresholds.

Parameters

• thresholds: Thresholds used to classify hot contention.

Returns

The updated builder.

pub fn isolate_listener_panics(self) -> Self

Enables retry-layer listener panic isolation.

Returns

The updated builder.

pub fn build(self) -> Result<CasExecutor<T, E>, RetryConfigError>

Builds one executor after validating the settings.

Returns

A validated CasExecutor.

Errors

Returns RetryConfigError when the configured retry settings are invalid.

pub fn build_contention_adaptive( self, ) -> Result<CasExecutor<T, E>, RetryConfigError>

Builds one executor with the contention-adaptive strategy.

Returns

A configured CasExecutor suitable for contended writers.

pub fn build_latency_first(self) -> Result<CasExecutor<T, E>, RetryConfigError>

Builds one executor with the latency-first strategy.

Returns

A configured CasExecutor optimized for low latency.

pub fn build_reliability_first( self, ) -> Result<CasExecutor<T, E>, RetryConfigError>

Builds one executor with the reliability-first strategy.

Returns

A configured CasExecutor optimized for long retry windows.

Trait Implementations

impl<T, E> Default for CasBuilder<T, E>

fn default() -> Self

Creates a default CAS builder.

Returns

A builder equivalent to CasBuilder::new.