Memory Fabric

#[async_trait]
pub trait MemoryProvider: Send + Sync {
    async fn store(&self, key: &str, value: Value) -> Result<(), MemoryError>;
    async fn store_entry(&self, entry: MemoryEntry) -> Result<(), MemoryError>;
    async fn retrieve(&self, key: &str) -> Result<Option<Value>, MemoryError>;
    async fn retrieve_entry(&self, key: &str) -> Result<Option<MemoryEntry>, MemoryError>;
    async fn query(&self, query: &MemoryQuery) -> Result<Vec<MemoryEntry>, MemoryError>;
    async fn delete(&self, key: &str) -> Result<(), MemoryError>;
    async fn exists(&self, key: &str) -> Result<bool, MemoryError>;
    fn backend_type(&self) -> BackendType;
    fn capabilities(&self) -> MemoryCapabilities;
    async fn ping(&self) -> Result<bool, MemoryError>;
}

use allternit_memory_fabric::{MemoryFabric, MemoryProvider, MemoryQuery};

let fabric = MemoryFabric::new_in_memory().await?;
fabric.store("greeting", serde_json::json!("hello")).await?;
let value = fabric.retrieve("greeting").await?;

pub struct MemoryEntry {
    pub id: String,
    pub key: String,
    pub value: Value,
    pub tags: Vec<String>,
    pub created_at: u64,
    pub updated_at: u64,
    pub expires_at: Option<u64>,
    pub tenant_id: Option<String>,
    pub session_id: Option<String>,
    pub embedding: Option<Vec<f32>>,
}

pub struct MemoryQuery {
    pub query: String,
    pub filters: HashMap<String, Value>,
    pub limit: Option<usize>,
    pub offset: Option<usize>,
    pub sort_by: Option<String>,
    pub ascending: Option<bool>,
    pub min_similarity: Option<f32>,
    pub tags: Vec<String>,
    pub tenant_id: Option<String>,
    pub session_id: Option<String>,
}

{
  "id": "<uuid>",
  "prev_hash": "<hex-sha256-or-null>",
  "content_hash": "<hex-sha256>",
  "content": {
    "op": "store",
    "key": "greeting",
    "value": "hello",
    "timestamp": 1234567890
  },
  "timestamp": 1234567890
}