Struct FailoverExecutor 

pub struct FailoverExecutor;

Failover execution utilities

Implementations

impl FailoverExecutor

pub async fn execute_with_failover<T, E, F, Fut>( manager: &FailoverManager, operation: F, ) -> Result<T, FailoverError<E>>

where F: Fn(FailoverContext) -> Fut + Send + Sync, Fut: Future<Output = Result<T, E>> + Send, E: Send + Sync + 'static,

Execute a function with failover logic

Errors

Returns an error if all endpoints fail, no endpoints are available, or the operation fails on all retry attempts.

Panics

This function should not panic under normal circumstances as the context is always initialized before use.

pub fn create_failover_notifier() -> (FailoverEventSender, FailoverEventReceiver)

Create a failover event notifier

pub fn validate_config(config: &FailoverConfig) -> Result<(), String>

Validate failover configuration

Errors

Returns an error if the configuration contains invalid values such as zero retries or zero delay.

pub fn create_basic_manager( endpoints: Vec<(String, String, i32)>, ) -> FailoverManager

Create a basic failover manager with default configuration

Trait Implementations

impl Debug for FailoverExecutor

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

Formats the value using the given formatter.