Struct BackupHandle 

pub struct BackupHandle {
    pub error_count: Arc<AtomicU64>,
    pub last_success_ts: Arc<AtomicU64>,
    pub healthy: Arc<AtomicBool>,
    pub lag_s: Arc<AtomicU64>,
    pub lease_held: Arc<AtomicBool>,
    pub reason: Arc<Mutex<Option<String>>>,
    pub join: JoinHandle<()>,
}

The running worker, as the serve loop holds it.

There is one way to stop it: send BackupTrigger::Shutdown (or drop the sender), then await join. It finishes within shutdown_grace_ms, however unresponsive the bucket is.

Fields

error_count: Arc<AtomicU64>

Failed steps since start (mushroomdb_backup_upload_errors_total).

last_success_ts: Arc<AtomicU64>

Unix seconds of the last moment everything durable was shipped; 0 before the first.

healthy: Arc<AtomicBool>

False after UNHEALTHY_AFTER_FAILURES consecutive failures, while durable data has stayed unshipped for longer than max(30 s, 10 × wal_interval), or for good once the worker has stopped; true otherwise.

lag_s: Arc<AtomicU64>

backup_lag_s: seconds the oldest durable, unshipped WAL byte has waited; 0 when everything durable is shipped.

lease_held: Arc<AtomicBool>

Whether this worker holds the bucket lease right now: false while another instance holds it, after the lease is lost or cannot be renewed, and once the worker has released it.

reason: Arc<Mutex<Option<String>>>

Why the worker is unhealthy, while it is; once it has stopped, why it stopped ("stopped" after a shutdown, the panic message after a panic).

join: JoinHandle<()>

Finishes when the worker has flushed and stopped.

Trait Implementations

impl Debug for BackupHandle

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

Formats the value using the given formatter.