vector/lib/gridstore/benches/bustle_bench/main.rs

//! Implements Bustle traits for comparing performance against other kv stores.
#[cfg(feature = "rocksdb")]
use ::rocksdb::DB;
use bustle::{Mix, Workload};
use fixture::ArcStorage;
use gridstore::Gridstore;
use gridstore::fixtures::Payload;

mod fixture;
mod payload_storage;
#[cfg(feature = "rocksdb")]
mod rocksdb;

type PayloadStorage = Gridstore<Payload>;

fn default_opts(workload: &mut Workload) -> &mut Workload {
    let seed = [42; 32];
    workload.initial_capacity_log2(21).seed(seed)
}

fn main() {
    for num_threads in [1, 2] {
        println!("------------ {num_threads} thread(s) -------------");
        // Read heavy
        println!("**read_heavy** with prefill_fraction 0.95");
        let mut workload = Workload::new(num_threads, Mix::read_heavy());
        default_opts(&mut workload).prefill_fraction(0.95);
        println!("ValueStorage:");
        workload.run::<ArcStorage<PayloadStorage>>();

        #[cfg(feature = "rocksdb")]
        {
            println!("RocksDB:");
            workload.run::<ArcStorage<DB>>();
        }
        println!(" ");

        // Insert heavy
        println!("**insert_heavy** with prefill_fraction 0.2");
        let mut workload = Workload::new(num_threads, Mix::insert_heavy());
        default_opts(&mut workload).prefill_fraction(0.2);

        println!("ValueStorage:");
        workload.run::<ArcStorage<PayloadStorage>>();

        #[cfg(feature = "rocksdb")]
        {
            println!("RocksDB:");
            workload.run::<ArcStorage<DB>>();
        }
        println!(" ");

        // Update heavy
        println!("**update_heavy** with prefill_fraction 0.95");
        let mut workload = Workload::new(num_threads, Mix::update_heavy());
        default_opts(&mut workload).prefill_fraction(0.95);

        println!("ValueStorage:");
        workload.run::<ArcStorage<PayloadStorage>>();

        #[cfg(feature = "rocksdb")]
        {
            println!("RocksDB:");
            workload.run::<ArcStorage<DB>>();
        }
        println!(" ");
    }
}