Struct ResilientClientConfig 

pub struct ResilientClientConfig {

    pub bootstrap_servers: Vec<String>,
    pub pool_size: usize,
    pub retry_max_attempts: u32,
    pub retry_initial_delay: Duration,
    pub retry_max_delay: Duration,
    pub retry_multiplier: f64,
    pub circuit_breaker_threshold: u32,
    pub circuit_breaker_timeout: Duration,
    pub circuit_breaker_success_threshold: u32,
    pub connection_timeout: Duration,
    pub request_timeout: Duration,
    pub health_check_interval: Duration,
    pub health_check_enabled: bool,
}

Configuration for the resilient client

Fields

bootstrap_servers: Vec<String>

Bootstrap servers (host:port)

pool_size: usize

Connection pool size per server

retry_max_attempts: u32

Maximum retry attempts

retry_initial_delay: Duration

Initial retry delay

retry_max_delay: Duration

Maximum retry delay

retry_multiplier: f64

Retry backoff multiplier

circuit_breaker_threshold: u32

Circuit breaker failure threshold

circuit_breaker_timeout: Duration

Circuit breaker recovery timeout

circuit_breaker_success_threshold: u32

Circuit breaker half-open success threshold

connection_timeout: Duration

Connection timeout

request_timeout: Duration

Request timeout

health_check_interval: Duration

Health check interval

health_check_enabled: bool

Enable automatic health checking

Implementations

impl ResilientClientConfig

pub fn builder() -> ResilientClientConfigBuilder

Create a new builder

Trait Implementations

impl Clone for ResilientClientConfig

fn clone(&self) -> ResilientClientConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResilientClientConfig

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

Formats the value using the given formatter.

impl Default for ResilientClientConfig

fn default() -> Self

Returns the “default value” for a type.