memoryhub 0.0.1

Centralized memory service for AI agents
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

//! Error types for the Memory Manager sub-system.

use std::path::PathBuf;

use acktor::error::{BoxError, RecvError, SendError};
use thiserror::Error;

/// Errors from filesystem storage operations.
#[derive(Debug, Error)]
pub enum StorageError {
    #[error("storage I/O error at {}", path.display())]
    Io {
        path: PathBuf,
        source: std::io::Error,
    },
}

/// Errors from index operations.
#[derive(Debug, Error)]
pub enum IndexError {
    #[error(transparent)]
    Sqlite(#[from] rusqlite::Error),

    #[error(transparent)]
    TaskJoin(#[from] tokio::task::JoinError),

    #[error("embedding dimension mismatch: stored={stored}, received={received}")]
    DimensionMismatch { stored: usize, received: usize },
}

/// Top-level error for Memory Manager operations.
#[derive(Debug, Error)]
pub enum MemoryError {
    #[error(transparent)]
    Storage(#[from] StorageError),

    #[error(transparent)]
    Indexer(#[from] IndexError),

    #[error(transparent)]
    Llm(#[from] crate::llm::LlmError),

    #[error("could not send message")]
    SendError(#[source] BoxError),

    #[error("could not receive message")]
    RecvError(#[from] RecvError),
}

impl<M> From<SendError<M>> for MemoryError
where
    M: Send + Sync + 'static,
{
    fn from(e: SendError<M>) -> Self {
        Self::SendError(e.into())
    }
}