Function main

example/simple.rs:8–57

()

#[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 s1 = Storage::<Pid, User>::open(ops).await.unwrap();

    // insert to memory and send to (disk_log) and (reporter)
    s1.insert("+98 9370156893".to_owned(), User::new("DanyalMh"))
        .await
        .unwrap();

    {
        let opd = s1.lookup(&"+98 9370156893".to_string()).unwrap();
        println!("==> {:?}", opd.value());
    }

    // remove from memory and send to (disk_log) and (reporter)
    s1.remove("+98 9370156893".to_owned()).await;

    

    // iter over storage
    s1.iter().for_each(|r| {
        println!("==> {}-{:?}", r.key(), r.value());
    })
}

type Pid = String;