Struct MigrationHistoryManager 

pub struct MigrationHistoryManager { /* private fields */ }

In-memory manager for migration history. Persisted as JSON.

Implementations

impl MigrationHistoryManager

pub fn new() -> MigrationHistoryManager

pub fn record( &mut self, rec: MigrationHistoryRecord, ) -> Result<(), StorageError>

pub fn list( &self, space: &str, label: &str, is_edge: bool, ) -> Vec<MigrationHistoryRecord>

pub fn list_all(&self) -> Vec<MigrationHistoryRecord>

pub fn get_applied_versions( &self, space: &str, label: &str, is_edge: bool, ) -> HashSet<u64>

pub fn get_applied_versions_sorted( &self, space: &str, label: &str, is_edge: bool, ) -> Vec<u64>

pub fn check_chain( applied_sorted: &[u64], space: &str, label: &str, is_edge: bool, from_version: u64, to_version: u64, ) -> Result<(), StorageError>

Check a plan’s version range against already-applied versions.

Pure function over a sorted applied list so both the storage engine and the migration executor share one chain rule: forward-only ranges, no re-applying an applied target, and no gaps (a non-empty chain must continue exactly where it left off).

pub fn validate_version_chain( &self, space: &str, label: &str, is_edge: bool, from_version: u64, to_version: u64, ) -> Result<(), StorageError>

Instance form of Self::check_chain over this manager’s records.

pub fn find( &self, space: &str, label: &str, is_edge: bool, to_version: u64, ) -> Option<MigrationHistoryRecord>

pub fn save_to_file(&self, path: &Path) -> Result<(), StorageError>

pub fn load_from_file( path: &Path, ) -> Result<MigrationHistoryManager, StorageError>

pub fn clear(&mut self)

Trait Implementations

impl Clone for MigrationHistoryManager

fn clone(&self) -> MigrationHistoryManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MigrationHistoryManager

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

Formats the value using the given formatter.

impl Default for MigrationHistoryManager

fn default() -> MigrationHistoryManager

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MigrationHistoryManager

fn deserialize<__D>( __deserializer: __D, ) -> Result<MigrationHistoryManager, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MigrationHistoryManager

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

where __S: Serializer,

Serialize this value into the given Serde serializer.