stub out for rocksdb

Author: uniphil

link_aggregator/src/main.rs

@@ -12,12 +12,13 @@ use tokio::runtime;
 
 use consumer::consume;
 use server::serve;
-use storage::MemStorage;
+use storage::{MemStorage, RocksStorage};
 
 fn main() -> Result<()> {
     println!("starting...");
 
     let storage = MemStorage::new();
+    let _ = RocksStorage::new(); // todo: switch storage to this
 
     let qsize = Arc::new(AtomicU32::new(0));
 

link_aggregator/src/storage/mod.rs

@@ -5,6 +5,9 @@ use links::CollectedLink;
 pub mod mem_store;
 pub use mem_store::MemStorage;
 
+pub mod rocks_store;
+pub use rocks_store::RocksStorage;
+
 /// consumer-side storage api, independent of actual storage backend
 pub trait LinkStorage: StorageBackend {
     fn push(&self, event: &ActionableEvent) -> Result<()> {
@@ -48,8 +51,10 @@ mod tests {
         ($test_name:ident, |$storage_label:ident| $test_code:block) => {
             #[test]
             fn $test_name() -> Result<()> {
-                let __stores: Vec<(&str, Box<dyn LinkStorage>)> =
-                    vec![("memstorage", Box::new(MemStorage::new()))];
+                let __stores: Vec<(&str, Box<dyn LinkStorage>)> = vec![
+                    ("memstorage", Box::new(MemStorage::new())),
+                    ("rocksdb", Box::new(RocksStorage::new())),
+                ];
                 for (__backend_name, __storage) in __stores {
                     println!("=> testing with {__backend_name} backend");
                     let $storage_label = __storage;

link_aggregator/src/storage/rocks_store.rs

@@ -0,0 +1,41 @@
+use super::{LinkStorage, StorageBackend};
+use anyhow::Result;
+use link_aggregator::{Did, RecordId};
+use links::CollectedLink;
+
+// hopefully-correct simple hashmap version, intended only for tests to verify disk impl
+#[derive(Debug, Clone)]
+pub struct RocksStorage(RocksStorageData);
+
+#[derive(Debug, Clone)]
+struct RocksStorageData {}
+
+impl RocksStorage {
+    pub fn new() -> Self {
+        Self(RocksStorageData {})
+    }
+}
+
+impl LinkStorage for RocksStorage {} // defaults are fine
+
+impl StorageBackend for RocksStorage {
+    fn add_links(&self, _record_id: &RecordId, _links: &[CollectedLink]) {
+        todo!()
+    }
+
+    fn set_account(&self, _did: &Did, _active: bool) {
+        todo!()
+    }
+
+    fn remove_links(&self, _record_id: &RecordId) {
+        todo!()
+    }
+
+    fn delete_account(&self, _did: &Did) {
+        todo!()
+    }
+
+    fn count(&self, _target: &str, _collection: &str, _path: &str) -> Result<u64> {
+        todo!()
+    }
+}