Struct ResilientConfig 

pub struct ResilientConfig {
    pub backoff: Backoff,
    pub lag_policy: LagPolicy,
    pub cursor_store: Arc<dyn CursorStore>,
}

Bundles the resilience knobs for StreamClient::resilient_subscribe.

Fields

backoff: Backoff

Reconnect backoff schedule.

lag_policy: LagPolicy

What to do with Lagged notices.

cursor_store: Arc<dyn CursorStore>

Where the resume cursor is persisted.

Implementations

impl ResilientConfig

pub fn new() -> Self

Start from the defaults (forever-retry backoff, LagPolicy::AutoResume, no persistence).

pub fn cursor_store(self, store: Arc<dyn CursorStore>) -> Self

Persist the resume cursor through store.

pub fn backoff(self, backoff: Backoff) -> Self

Override the reconnect backoff.

pub fn lag_policy(self, policy: LagPolicy) -> Self

Override the lag policy.

Trait Implementations

impl Debug for ResilientConfig

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

Formats the value using the given formatter.

impl Default for ResilientConfig

fn default() -> Self

Returns the “default value” for a type.