Struct FakeExecutor 

pub struct FakeExecutor {
    pub call_count: Arc<AtomicUsize>,
    pub reconnect_count: Arc<AtomicUsize>,
    /* private fields */
}

Fake executor for testing retry behavior.

Configured with a sequence of results to return. Each call to execute_command consumes the next result. After exhausting the sequence, returns Ok(()).

Fields

call_count: Arc<AtomicUsize>

Counter of how many times execute_command was called.

reconnect_count: Arc<AtomicUsize>

Counter of how many times reconnect was called.

Implementations

impl FakeExecutor

pub fn new(results: Vec<Result<(), FakeError>>) -> Self

Creates a new fake executor with the given result sequence.

pub fn call_count(&self) -> Arc<AtomicUsize>

Returns a shared reference to the call counter.

pub fn reconnect_count(&self) -> Arc<AtomicUsize>

Returns a shared reference to the reconnect counter.

Trait Implementations

impl RedisCommandExecutor for FakeExecutor

fn execute_command<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _cmd: &'life1 RedisCommand, _exchange: &'life2 mut Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a Redis command against the given exchange.

fn reconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reconnect the underlying connection.