Struct MasterComponentConfig 

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

Configuration for the master/leader-election component.

Controls drain timeout for graceful delegate shutdown and the maximum number of delegate start retry attempts while leading.

Fields

drain_timeout_ms: u64

Timeout in milliseconds for draining a delegate consumer on leadership loss.

delegate_retry_max_attempts: Option<u32>

Maximum number of times to retry starting the delegate consumer after a failure. None means unlimited retries.

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.