Struct CasExecutor 

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

Executor for retry-aware compare-and-swap workflows.

Implementations

impl<T, E> CasExecutor<T, E>

pub fn builder() -> CasBuilder<T, E>

Creates a CAS builder.

Returns

A builder configured with default retry settings.

pub fn from_options(options: RetryOptions) -> Result<Self, RetryConfigError>

Creates an executor from retry options.

Parameters

• options: Retry options to validate and install.

Returns

A configured executor using the default timeout policy.

Errors

Returns the retry-layer validation error when options are invalid.

pub fn latency_first() -> Self

Creates an executor tuned for low-latency workloads.

Returns

A configured executor. The built-in strategy is always valid.

pub fn contention_adaptive() -> Self

Creates an executor tuned for hot-contention workloads.

Returns

A configured executor. The built-in strategy is always valid.

pub fn reliability_first() -> Self

Creates an executor tuned for reliability-first workloads.

Returns

A configured executor. The built-in strategy is always valid.

pub fn with_strategy(strategy: CasStrategy) -> Self

Creates an executor from a built-in strategy.

Parameters

• strategy: Strategy to install.

Returns

A configured executor. Built-in strategies are always valid.

pub fn options(&self) -> &RetryOptions

Returns the immutable retry options used by this executor.

Returns

Shared retry options.

pub fn attempt_timeout(&self) -> Option<Duration>

Returns the configured async attempt timeout.

Returns

Some(Duration) when async attempts have a timeout.

pub fn timeout_policy(&self) -> CasTimeoutPolicy

Returns the timeout policy.

Returns

Policy used when an async attempt exceeds the timeout.

pub fn observability(&self) -> &CasObservabilityConfig

Returns observability settings used by this executor.

Returns

Shared observability configuration.

pub fn execute<R, O>( &self, state: &AtomicRef<T>, operation: O, ) -> CasOutcome<T, R, E>

where T: 'static, E: 'static, O: Function<T, CasDecision<T, R, E>>,

Executes one synchronous CAS operation.

Parameters

• state: Shared atomic state container.
• operation: Pure operation that inspects the current state and returns a CAS decision.

Returns

A terminal result together with the execution report.

pub fn execute_with_hooks<R, O>( &self, state: &AtomicRef<T>, operation: O, hooks: CasHooks, ) -> CasOutcome<T, R, E>

where T: 'static, E: 'static, O: Function<T, CasDecision<T, R, E>>,

Executes one synchronous CAS operation with lifecycle hooks.

Parameters

• state: Shared atomic state container.
• operation: Pure operation that inspects the current state and returns a CAS decision.
• hooks: Per-execution hook registrations.

Returns

A terminal result together with the execution report.

pub async fn execute_async<R, O, Fut>( &self, state: &AtomicRef<T>, operation: O, ) -> CasOutcome<T, R, E>

where T: 'static, E: 'static, O: Fn(Arc<T>) -> Fut, Fut: Future<Output = CasDecision<T, R, E>>,

Executes one asynchronous CAS operation.

Parameters

• state: Shared atomic state container.
• operation: Async operation factory receiving one state snapshot.

Returns

A terminal result together with the execution report.

pub async fn execute_async_with_hooks<R, O, Fut>( &self, state: &AtomicRef<T>, operation: O, hooks: CasHooks, ) -> CasOutcome<T, R, E>

where T: 'static, E: 'static, O: Fn(Arc<T>) -> Fut, Fut: Future<Output = CasDecision<T, R, E>>,

Executes one asynchronous CAS operation with lifecycle hooks.

Parameters

• state: Shared atomic state container.
• operation: Async operation factory receiving one state snapshot.
• hooks: Per-execution hook registrations.

Returns

A terminal result together with the execution report.

Trait Implementations

impl<T: Clone, E: Clone> Clone for CasExecutor<T, E>

fn clone(&self) -> CasExecutor<T, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug, E: Debug> Debug for CasExecutor<T, E>

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

Formats the value using the given formatter.