Struct ResilientOptions 

pub struct ResilientOptions {
    pub manager_options: ManagerOptions,
    pub buffer_size: usize,
    pub enable_heartbeat: bool,
    pub enable_watchdog: bool,
    pub heartbeat_interval: u64,
    pub watchdog_interval: u64,
    pub max_retries: u32,
    pub metrics: Option<ResilientMetrics>,
    pub cumulative_attempts_counter: Option<Arc<AtomicU64>>,
}

Configuration options for resilient AMI connections

Fields

manager_options: ManagerOptions

Basic connection options

buffer_size: usize

Buffer size for event broadcaster (default: 2048)

enable_heartbeat: bool

Enable heartbeat monitoring (default: true)

enable_watchdog: bool

Enable automatic reconnection watchdog (default: true)

heartbeat_interval: u64

Heartbeat interval in seconds (default: 30)

watchdog_interval: u64

Watchdog check interval in seconds (default: 1)

max_retries: u32

Maximum number of immediate reconnection attempts before adding delays. Retry behavior: first max_retries attempts are immediate (no delay), followed by one delayed attempt, then the counter resets and the cycle repeats. Default: 3.

metrics: Option<ResilientMetrics>

Optional metrics collection for monitoring reconnection behavior

cumulative_attempts_counter: Option<Arc<AtomicU64>>

Global cumulative attempts counter shared across stream instances

Implementations

impl ResilientOptions

pub fn with_global_counter(self) -> Self

Create a new ResilientOptions with a shared global cumulative attempts counter. This ensures that cumulative attempt counts persist across stream recreation.

Trait Implementations

impl Clone for ResilientOptions

fn clone(&self) -> ResilientOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResilientOptions

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

Formats the value using the given formatter.

impl Default for ResilientOptions

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ResilientOptions

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ResilientOptions

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.