Function mz_rocksdb::rocksdb_core_loop

source ·
pub(crate) fn rocksdb_core_loop<K, V, M, O, IM, F>(
    options: InstanceOptions<O, V, F>,
    tuning_config: RocksDBConfig,
    instance_path: PathBuf,
    cmd_rx: Receiver<Command<K, V>>,
    shared_metrics: M,
    instance_metrics: IM,
    creation_error_tx: Sender<Error>
)
where K: AsRef<[u8]> + Send + Sync + 'static, V: Serialize + DeserializeOwned + Send + Sync + 'static, M: Deref<Target = RocksDBSharedMetrics> + Send + 'static, O: Options + Copy + Send + Sync + 'static, F: for<'a> Fn(&'a [u8], ValueIterator<'a, O, V>) -> V + Send + Sync + Copy + 'static, IM: Deref<Target = RocksDBInstanceMetrics> + Send + 'static,