Struct BackupExecutionJournal 

pub struct BackupExecutionJournal {
    pub journal_version: u16,
    pub plan_id: String,
    pub run_id: String,
    pub preflight_id: Option<String>,
    pub preflight_accepted: bool,
    pub restart_required: bool,
    pub operations: Vec<BackupExecutionJournalOperation>,
    pub operation_receipts: Vec<BackupExecutionOperationReceipt>,
}

BackupExecutionJournal

Durable execution journal for one backup plan run. Owned by backup execution and persisted for resume and integrity checks.

Fields

journal_version: u16

plan_id: String

run_id: String

preflight_id: Option<String>

preflight_accepted: bool

restart_required: bool

operations: Vec<BackupExecutionJournalOperation>

operation_receipts: Vec<BackupExecutionOperationReceipt>

Implementations

impl BackupExecutionJournal

pub fn from_plan(plan: &BackupPlan) -> Result<Self, BackupExecutionJournalError>

Build an execution journal from a validated backup plan.

pub fn validate(&self) -> Result<(), BackupExecutionJournalError>

Validate journal structure and operation receipts.

pub fn accept_preflight_bundle_at( &mut self, preflight_id: String, updated_at: Option<String>, ) -> Result<(), BackupExecutionJournalError>

Mark all preflight operations completed and unblock mutating operations.

pub fn accept_preflight_receipts_at( &mut self, receipts: &BackupExecutionPreflightReceipts, updated_at: Option<String>, ) -> Result<(), BackupExecutionJournalError>

Accept a typed preflight receipt bundle and unblock mutating operations.

pub fn next_ready_operation(&self) -> Option<&BackupExecutionJournalOperation>

Return the next operation that should control runner progress.

pub fn mark_next_operation_pending_at( &mut self, updated_at: Option<String>, ) -> Result<(), BackupExecutionJournalError>

Mark the next transitionable operation pending.

pub fn mark_operation_pending_at( &mut self, sequence: usize, updated_at: Option<String>, ) -> Result<(), BackupExecutionJournalError>

Mark one operation pending.

pub fn mark_snapshot_create_pending_at( &mut self, sequence: usize, updated_at: Option<String>, snapshot_ids_before: Vec<String>, ) -> Result<(), BackupExecutionJournalError>

Mark one snapshot-create operation pending with its exact pre-effect inventory.

pub fn record_operation_receipt( &mut self, receipt: BackupExecutionOperationReceipt, ) -> Result<(), BackupExecutionJournalError>

Record one operation receipt and transition the matching operation.

pub fn retry_failed_operation_at( &mut self, sequence: usize, updated_at: Option<String>, ) -> Result<(), BackupExecutionJournalError>

Move a failed operation back to ready for retry.

pub fn resume_summary(&self) -> BackupExecutionResumeSummary

Build a compact resumability summary.

Trait Implementations

impl Clone for BackupExecutionJournal

fn clone(&self) -> BackupExecutionJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackupExecutionJournal

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BackupExecutionJournal

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BackupExecutionJournal

impl PartialEq for BackupExecutionJournal

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for BackupExecutionJournal

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 BackupExecutionJournal