Function main

example/migrate_to_another_database.rs:3–44

()

#[tokio::main]
async fn main() {


    // path can be '.' in storage::open
    let path           = ".";

    let storage_name   = "blackbird";
    let total_page_size = 1000;

    // ** RamCopies ** 
    //     Dont log to disk and after shutdown , loss data

    let stype = StorageType::RamCopies ;

    // ** DiskCopies ** 
    //      whole storage operation is in-memory but log to disk, 
    //       automatic load whole data after restart, avoid any loss data
    //  
    // let stype = StorageType::DiskCopies;

    
    let ops = Options::new(path, storage_name, total_page_size, StorageType::RamCopies, true);


    // Storage is built for high concurrency usage
    // dont need to Mutex / Rwlock, it is safe for shared between thread 
    //
    // create storage and initialize other service (reporter, disk_log)  
    //
    // when calling storage::open, it load whole storage from disk
    //
    
    let s = Arc::new(Storage::<Pid, User>::open(ops).await.unwrap());
    
    let pw = Persistent::connect(DatabaseName::Postgres, "host=localhost user=postgres").await.unwrap();
    
    // Copy Table to database
    pw.copy_memtable_to_database(s.clone(), &WriteToDatabase).await;
    
    
    
}


struct WriteToDatabase;