Struct MasterComponentConfig 

pub struct MasterComponentConfig {
    pub drain_timeout_ms: u64,
    pub reconnect: NetworkRetryPolicy,
    pub delegate_retry_max_attempts: Option<u32>,
}

Configuration for the master/leader-election component.

Controls drain timeout for graceful delegate shutdown and reconnection policy.

Backward compatibility

The delegate_retry_max_attempts field is retained as a backward-compat alias. When set (not None), it bridges into reconnect.max_attempts during construction in MasterComponent::new(). If reconnect is also explicitly configured, the explicit reconnect value wins.

Fields

drain_timeout_ms: u64

Timeout in milliseconds for draining a delegate consumer on leadership loss. The drain runs after leadership is lost and may overlap a successor’s lease; see the README “How It Works” section.

reconnect: NetworkRetryPolicy

Structured reconnection policy, replacing the flat delegate_retry_max_attempts field for new configs. Default: unlimited (max_attempts=0).

delegate_retry_max_attempts: Option<u32>

Backward-compat alias for reconnect.max_attempts. None means unlimited. Bridged into reconnect during MasterComponent::new().

Implementations

impl MasterComponentConfig

pub fn new( drain_timeout_ms: u64, delegate_retry_max_attempts: Option<u32>, ) -> Self

Create a new config with the given drain timeout and retry limit.

Trait Implementations

impl Clone for MasterComponentConfig

fn clone(&self) -> MasterComponentConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MasterComponentConfig

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

Formats the value using the given formatter.

impl Default for MasterComponentConfig

fn default() -> Self

Returns the “default value” for a type.