Struct RecoveryRecord 

pub struct RecoveryRecord {
    pub at: DateTime<Utc>,
    pub workload: String,
    pub node: String,
    pub tier: Option<String>,
    pub subject: String,
    pub bytes: u64,
    pub seconds: f64,
    pub helper: String,
}

One subject’s measured restore, appended to .yah/cloud/recovery.jsonl.

bytes and seconds are the helper’s own measured figures, copied unmodified. at is when the measurement was ingested — the helper emits no timestamp of its own, so for a line piped straight out of a restore this is within seconds of the event, and for a replayed old log it is not. Use RecoveryRecord::from_helper_json_at when the real time is known.

Fields

at: DateTime<Utc>

workload: String

node: String

tier: Option<String>

The durability tier the restore read from, when the operator said so. The helper does not print it — it reads TIER from its environment and emits per-subject source object keys instead — so this is None unless attributed at ingest.

subject: String

bytes: u64

seconds: f64

helper: String

Implementations

impl RecoveryRecord

pub fn from_helper_json( line: &str, workload: &str, node: &str, ) -> Result<Vec<Self>>

Parse one line of turso-backup-hydrate output into one record per restored subject, stamped with the current time.

A well-formed line reporting no restore (already_populated, a refusal) yields an empty vec — that is an answer, not an error. Only a line that is not the helper’s JSON at all is an Err.

pub fn from_helper_json_at( line: &str, workload: &str, node: &str, at: DateTime<Utc>, ) -> Result<Vec<Self>>

from_helper_json with the ingest timestamp supplied — for tests, and for ingesting a log whose real time is known.

pub fn with_tier(self, tier: impl Into<String>) -> Self

Attribute these records to a durability tier the helper did not print.

Trait Implementations

impl Clone for RecoveryRecord

fn clone(&self) -> RecoveryRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecoveryRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecoveryRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RecoveryRecord

fn eq(&self, other: &RecoveryRecord) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RecoveryRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RecoveryRecord