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,