aboutsummaryrefslogtreecommitdiff
path: root/src/storage/in_memory.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2023-11-02 10:38:47 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2023-11-02 10:38:47 +0100
commit9aa58194d44fef8b0b916f6c96edd124ce13bf7b (patch)
tree7d8fecdddad2212096fd8a36a03805d5aaee3114 /src/storage/in_memory.rs
parent415f51ac4cfc723bbf6f0c08d57fb86e96c665a2 (diff)
downloadaerogramme-9aa58194d44fef8b0b916f6c96edd124ce13bf7b.tar.gz
aerogramme-9aa58194d44fef8b0b916f6c96edd124ce13bf7b.zip
try dynamic dispatch
Diffstat (limited to 'src/storage/in_memory.rs')
-rw-r--r--src/storage/in_memory.rs17
1 files changed, 9 insertions, 8 deletions
diff --git a/src/storage/in_memory.rs b/src/storage/in_memory.rs
index dc3d1e1..fe7c93f 100644
--- a/src/storage/in_memory.rs
+++ b/src/storage/in_memory.rs
@@ -1,45 +1,46 @@
use crate::storage::*;
+#[derive(Clone, Debug)]
pub struct MemCreds {}
pub struct MemStore {}
pub struct MemRef {}
pub struct MemValue {}
impl IRowBuilder for MemCreds {
- fn row_store(&self) -> MemStore {
+ fn row_store(&self) -> RowStore {
unimplemented!();
}
}
impl IRowStore for MemStore {
- fn new_row(&self, partition: &str, sort: &str) -> MemRef {
+ fn new_row(&self, partition: &str, sort: &str) -> RowRef {
unimplemented!();
}
}
impl IRowRef for MemRef {
- fn set_value(&self, content: Vec<u8>) -> MemValue {
+ fn set_value(&self, content: Vec<u8>) -> RowValue {
unimplemented!();
}
- async fn fetch(&self) -> Result<MemValue, Error> {
+ fn fetch(&self) -> AsyncResult<RowValue> {
unimplemented!();
}
- async fn rm(&self) -> Result<(), Error> {
+ fn rm(&self) -> AsyncResult<()> {
unimplemented!();
}
- async fn poll(&self) -> Result<Option<MemValue>, Error> {
+ fn poll(&self) -> AsyncResult<Option<RowValue>> {
unimplemented!();
}
}
impl IRowValue for MemValue {
- fn to_ref(&self) -> MemRef {
+ fn to_ref(&self) -> RowRef {
unimplemented!();
}
fn content(&self) -> ConcurrentValues {
unimplemented!();
}
- async fn push(&self) -> Result<(), Error> {
+ fn push(&self) -> AsyncResult<()> {
unimplemented!();
}
}