Struct StorageMirrorSync 

pub struct StorageMirrorSync {
    pub local_id: MirrorId,
    pub local_state: HashMap<String, SyncItem>,
    pub remote_states: HashMap<MirrorId, HashMap<String, SyncItem>>,
    pub default_resolution: MsConflictResolution,
    pub audit_log: VecDeque<SyncOperation>,
    /* private fields */
}

Bidirectional synchronisation between storage mirrors.

Maintains the local state, one or more remote mirror states, resolves conflicts, executes sync plans, and retains a bounded audit log.

Fields

local_id: MirrorId

The identifier for the local mirror.

local_state: HashMap<String, SyncItem>

Current state of the local mirror (CID → SyncItem).

remote_states: HashMap<MirrorId, HashMap<String, SyncItem>>

States of all registered remote mirrors.

default_resolution: MsConflictResolution

Default strategy for automatically resolving conflicts.

audit_log: VecDeque<SyncOperation>

Bounded audit log of executed operations (newest at the back).

Implementations

impl StorageMirrorSync

pub fn new(local_id: MirrorId, default_resolution: MsConflictResolution) -> Self

Creates a new StorageMirrorSync with the given local identifier and default conflict resolution strategy.

pub fn register_mirror(&mut self, mirror_id: MirrorId)

Registers a remote mirror. If the mirror is already registered this is a no-op.

pub fn update_local(&mut self, item: SyncItem) -> bool

Inserts or updates an item in the local state.

Returns true if the CID was not previously present (new insertion).

pub fn remove_local(&mut self, cid: &str) -> bool

Removes an item from the local state by CID.

Returns true if the item existed and was removed.

pub fn update_remote(&mut self, mirror_id: &MirrorId, item: SyncItem) -> bool

Inserts or updates an item in a remote mirror’s state.

Returns true if the CID was not previously present in that mirror. Returns false if the mirror is not registered.

pub fn diff(&self, mirror_id: &MirrorId) -> SyncPlan

Computes the set of operations needed to synchronise the local mirror with mirror_id.

Conflict resolution follows self.default_resolution.

pub fn apply_plan(&mut self, plan: &SyncPlan, now: u64) -> MsSyncResult

Simulates executing all operations in plan, updating local/remote states and audit log.

now is the UNIX timestamp (ms) to stamp on newly created items.

pub fn detect_conflicts(&self, mirror_id: &MirrorId) -> Vec<SyncConflict>

Returns all CIDs present in both local and mirror_id that have differing checksums.

pub fn local_only_cids(&self, mirror_id: &MirrorId) -> Vec<&str>

Returns all CIDs present only in the local state (not in mirror_id), sorted.

pub fn remote_only_cids(&self, mirror_id: &MirrorId) -> Vec<&str>

Returns all CIDs present only in mirror_id (not in local state), sorted.

pub fn in_sync_with(&self, mirror_id: &MirrorId) -> bool

Returns true when every CID in both local and mirror_id has the same checksum.

Returns false for unregistered mirrors.

pub fn audit_log_tail(&self, n: usize) -> Vec<&SyncOperation>

Returns up to the n most-recently logged operations (newest last).

pub fn stats(&self) -> MirrorSyncStats

Returns aggregate statistics for this instance.