Struct StatusOutput 

pub struct StatusOutput {
    pub job: Option<Checkpoint>,
    pub runtime: Option<RuntimeStatus>,
    pub source: Option<SourceStatus>,
    pub slot: Option<SlotInfo>,
    pub source_wal_lsn: Option<Lsn>,
    pub slot_lag_bytes: Option<u64>,
    pub retained_wal_bytes: Option<u64>,
    pub seconds_since_last_commit: Option<f64>,
    pub snapshot: SnapshotStatus,
    pub tables: Vec<TableSyncRow>,
    pub resync_required: bool,
    pub action: Option<String>,
}

Fields

job: Option<Checkpoint>

runtime: Option<RuntimeStatus>

Last heartbeat of the process running this job, if any was ever written.

source: Option<SourceStatus>

slot: Option<SlotInfo>

source_wal_lsn: Option<Lsn>

slot_lag_bytes: Option<u64>

retained_wal_bytes: Option<u64>

seconds_since_last_commit: Option<f64>

Seconds between now and the commit time of the last applied source transaction.

snapshot: SnapshotStatus

tables: Vec<TableSyncRow>

resync_required: bool

action: Option<String>

Operator action, when one is needed.

Trait Implementations

impl Serialize for StatusOutput

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.