WIP traits for the storage

2 files changed, 33 insertions, 0 deletions

diff --git a/src/main.rs b/src/main.rs
index 4ca07d0..2f6d512 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -7,6 +7,7 @@ mod lmtp;
 mod login;
 mod mail;
 mod server;
+mod storage;
 mod time;
 
 use std::path::PathBuf;
diff --git a/src/storage/mod.rs b/src/storage/mod.rs
new file mode 100644
index 0000000..399a416
--- /dev/null
+++ b/src/storage/mod.rs
@@ -0,0 +1,32 @@
+pub trait RowStore<K: RowRef, E> {
+    fn new_row_ref(partition: &str, sort: &str) -> K<E>;
+}
+
+pub trait RowRef {
+    fn set_value(&self, content: &[u8]) -> RowValue;
+    async fn get(&self) -> Result<RowValue, E>;
+    async fn rm(&self) -> Result<(), E>;
+    async fn obs(&self) -> Result<Option<RowValue>, ()>;
+}
+
+pub trait RowValue {
+    fn row_ref(&self) -> RowRef;
+    fn content(&self) -> Vec<u8>;
+    async fn put(&self) -> Result<(), E>;
+}
+
+/*
+    async fn get_many_keys(&self, keys: &[K]) -> Result<Vec<V>, ()>;
+    async fn put_many_keys(&self, values: &[V]) -> Result<(), ()>;
+}*/
+
+pub trait BlobStore {
+    fn new_blob_ref(key: &str) -> BlobRef;
+    async fn list(&self) -> ();
+}
+
+pub trait BlobRef {
+    async fn put(&self, key: &str, body: &[u8]) -> ();
+    async fn copy(&self, dst: &BlobRef) -> ();
+    async fn rm(&self, key: &str);
+}