Function main

example/new_features_vsn2.rs:3–55

()

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

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

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


    // **** Performance Improve vsn-2 ****
    //
    // Prev version :
    //   when insert key/doc, clone (key, document) for 
    //   send to reporter channel EVEN if not EXIST ANY subscriber
    // 
    // New version : ( ``` off_reporter() ``` )
    //   if reporter is off dont clone 
    //

    let s = Arc::new(Storage::<Pid, User>::open(ops)
                        .await
                        .unwrap()
                        .off_reporter());
    
    
    s1.insert("+98 9370156893".to_owned(), User::new("DanyalMh1")).await;
    s1.insert("+98 939.......".to_owned(), User::new("DanyalMh2")).await;
    s1.insert("+98 939.......".to_owned(), User::new("DanyalMh3")).await;
    


    // **** New Feature vsn-2 ****
    //
    //  Note:     
    //     Persistent Getter and Setter is complete safe, 
    //     can run Insert/Remove/Lookup on storage also 
    //     concurrently call (copy_memtable_to_database) and (load_memtable_from_database) in that 
    //
    //
    let cfg_string = "host=localhost user=postgres".to_string();
    let pers = Persistent::connect(DatabaseName::Postgres, cfg_string).await.unwrap();
    let h = Handler;

    h.init().await;

    // Copy table to postgres
    pers.copy_memtable_to_database(s1, &h).await;

    
    // Load table from postgres
    pers.load_memtable_from_database(s1, &h).await;
}


struct Handler;