Struct WorkerRecoveryConfig 

pub struct WorkerRecoveryConfig {
    pub heartbeat_interval: Duration,
    pub sweep_interval: Duration,
    pub sweep_threshold: Duration,
    pub recovery_delay: Duration,
    pub resilient_sweep_threshold_multiplier: u32,
    pub resilient_job_flags: Vec<String>,
    pub enabled: bool,
}

Dead worker recovery configuration.

Timing options align with Graphile Worker Pro:

• heartbeat_interval — heartbeatInterval
• sweep_interval — sweepInterval
• sweep_threshold — sweepThreshold

Fields

heartbeat_interval: Duration

Worker check-in frequency (heartbeatInterval).

sweep_interval: Duration

Inactive worker check frequency (sweepInterval).

sweep_threshold: Duration

Time since last heartbeat before a worker is deemed inactive (sweepThreshold).

recovery_delay: Duration

Delay before jobs recovered from dead workers are eligible to run again.

resilient_sweep_threshold_multiplier: u32

Multiplier applied to sweep_threshold when a worker holds jobs with resilient flags.

resilient_job_flags: Vec<String>

Job flags that trigger the extended sweep threshold.

enabled: bool

Whether heartbeat registration and sweeping are enabled.

Implementations

impl WorkerRecoveryConfig

pub fn heartbeat_interval(self, value: Duration) -> WorkerRecoveryConfig

pub fn sweep_interval(self, value: Duration) -> WorkerRecoveryConfig

pub fn sweep_threshold(self, value: Duration) -> WorkerRecoveryConfig

pub fn recovery_delay(self, value: Duration) -> WorkerRecoveryConfig

pub fn resilient_sweep_threshold_multiplier( self, value: u32, ) -> WorkerRecoveryConfig

pub fn resilient_job_flags(self, flags: Vec<String>) -> WorkerRecoveryConfig

pub fn enabled(self, value: bool) -> WorkerRecoveryConfig

Trait Implementations

impl Clone for WorkerRecoveryConfig

fn clone(&self) -> WorkerRecoveryConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerRecoveryConfig

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

Formats the value using the given formatter.

impl Default for WorkerRecoveryConfig

fn default() -> WorkerRecoveryConfig

Returns the “default value” for a type.