forked from
microcosm.blue/Allegedly
Server tools to backfill, tail, mirror, and verify PLC logs
plc_rocksdb: use opts on all cf's
+9
-3
+9
-3
src/plc_rocksdb.rs
+9
-3
src/plc_rocksdb.rs
···
1
-
use bytevec::BVSize;
2
1
use futures::stream;
3
-
use rocksdb::{BlockBasedOptions, DBCompressionType, Options, SliceTransform};
2
+
use rocksdb::{
3
+
BlockBasedOptions, ColumnFamilyDescriptor, DBCompressionType, Options, SliceTransform,
4
+
};
4
5
use std::{path::PathBuf, sync::Arc, time::Instant};
5
6
use tokio::sync::{Mutex, mpsc, oneshot};
6
7
use tokio_stream::StreamExt;
···
72
73
73
74
opts.set_block_based_table_factory(&block_opts);
74
75
75
-
let rdb = rocksdb::DB::open_cf(&opts, path, vec!["dids", "ops"])?;
76
+
let cfs = vec![
77
+
ColumnFamilyDescriptor::new("dids", opts.clone()),
78
+
ColumnFamilyDescriptor::new("ops", opts.clone()),
79
+
];
80
+
81
+
let rdb = rocksdb::DB::open_cf_descriptors(&opts, path, cfs)?;
76
82
77
83
Ok(RocksDatastore {
78
84
db: Arc::new(Mutex::new(rdb)),