Struct MaintenanceService 

pub struct MaintenanceService { /* private fields */ }

Maintenance service: runs leader-elected background tasks.

Tasks: heartbeat rescue, deadline rescue, scheduled promotion, cleanup, periodic job sync and evaluation.

Implementations

impl MaintenanceService

pub fn leader_election_interval(self, interval: Duration) -> Self

Set the leader election retry interval (default: 10s).

Controls how often a non-leader instance retries acquiring the advisory lock. Lower values speed up leader election in tests.

pub fn leader_check_interval(self, interval: Duration) -> Self

Set the leader connection health-check interval (default: 30s).

pub fn promote_interval(self, interval: Duration) -> Self

Set the promotion interval for scheduled/retryable jobs.

pub fn heartbeat_rescue_interval(self, interval: Duration) -> Self

Set the stale-heartbeat rescue interval (default: 30s).

pub fn deadline_rescue_interval(self, interval: Duration) -> Self

Set the deadline rescue interval (default: 30s).

pub fn callback_rescue_interval(self, interval: Duration) -> Self

Set the callback-timeout rescue interval (default: 30s).

pub fn heartbeat_staleness(self, staleness: Duration) -> Self

Set how long a heartbeat must be stale before the job is rescued (default: 90s).

Should be at least 3× the heartbeat interval to avoid false rescues from transient delays. The run-lease guard prevents duplicate completions even if a false rescue occurs, but wasted work is still undesirable.

pub fn cleanup_interval(self, interval: Duration) -> Self

Set the cleanup interval (default: 60s).

pub fn completed_retention(self, retention: Duration) -> Self

Set retention for completed jobs (default: 24h).

pub fn failed_retention(self, retention: Duration) -> Self

Set retention for failed/cancelled jobs (default: 72h).

pub fn cleanup_batch_size(self, batch_size: i64) -> Self

Set the maximum number of jobs to delete per cleanup pass (default: 1000).

pub fn queue_stats_interval(self, interval: Duration) -> Self

Set the interval for publishing queue depth/lag metrics (default: 30s).

pub fn queue_retention_overrides( self, overrides: HashMap<String, RetentionPolicy>, ) -> Self

Set per-queue retention overrides.

pub async fn run(&self)

Run the maintenance loop. Attempts leader election first.