Struct MigrationHelper 

pub struct MigrationHelper;

Migration helper providing utilities for transitioning between sync and async APIs

Implementations

impl MigrationHelper

pub async fn verify_compatibility( config: &Config, ) -> Result<CompatibilityReport>

Verify that a database is compatible with both sync and async APIs

This function checks that:

• The database can be opened with sync API
• The database can be opened with async API
• Both APIs can read the same data

Examples

use llm_memory_graph::{Config, migration::MigrationHelper};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("./data/graph.db");
    MigrationHelper::verify_compatibility(&config).await?;
    println!("Database is compatible!");
    Ok(())
}

pub async fn create_checkpoint(config: &Config) -> Result<MigrationCheckpoint>

Create a migration checkpoint that can be used to rollback if needed

This function creates a snapshot of database statistics that can be compared later to detect any issues during migration.

Examples

use llm_memory_graph::{Config, migration::MigrationHelper};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("./data/graph.db");
    let checkpoint = MigrationHelper::create_checkpoint(&config).await?;
    println!("Checkpoint: {} nodes, {} edges",
        checkpoint.node_count, checkpoint.edge_count);
    Ok(())
}

pub async fn verify_checkpoint( config: &Config, checkpoint: &MigrationCheckpoint, ) -> Result<CheckpointVerification>

Verify that a database hasn’t been corrupted after migration

Compares current state against a checkpoint created before migration.

Examples

use llm_memory_graph::{Config, migration::MigrationHelper};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("./data/graph.db");
    let before = MigrationHelper::create_checkpoint(&config).await?;

    // ... perform migration ...

    let result = MigrationHelper::verify_checkpoint(&config, &before).await?;
    assert!(result.valid, "Migration corrupted data!");
    Ok(())
}

pub async fn run_migration_test(config: &Config) -> Result<MigrationTestReport>

Run a test migration workflow to validate the migration process

This performs a complete migration test:

1. Creates a checkpoint
2. Tests sync API access
3. Tests async API access
4. Verifies data integrity

Examples

use llm_memory_graph::{Config, migration::MigrationHelper};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("./data/graph.db");
    let report = MigrationHelper::run_migration_test(&config).await?;
    println!("Migration test: {}", if report.success { "PASSED" } else { "FAILED" });
    Ok(())
}