Struct MemoryService 

pub struct MemoryService { /* private fields */ }

Implementations

impl MemoryService

pub fn new(store: Arc<dyn Store>) -> Self

pub fn with_config(store: Arc<dyn Store>, config: AdmissionConfig) -> Self

pub async fn store(&self, input: StoreMemoryInput) -> Memory

Store a new memory.

Runs the admission pipeline before persisting:

• memories that pass all checks are stored as Active
• memories that fail are stored as Rejected

pub async fn get( &self, memory_id: &MemoryId, ) -> Result<Option<Memory>, MemoryError>

Retrieve a memory by ID.

pub async fn update_content( &self, memory_id: &MemoryId, new_content: String, ) -> Result<(), MemoryError>

Update memory content.

Errors

Returns MemoryError::NotFound if the memory does not exist.

pub async fn transition_status( &self, memory_id: &MemoryId, new_status: MemoryStatus, ) -> Result<(), MemoryError>

Transition memory status.

Valid transitions:

• Candidate → {Scanning, Rejected}
• Scanning → {Verified, Rejected}
• Verified → Active
• Active → {Expired, Rejected}

Errors

Returns MemoryError::InvalidTransition if the transition is not allowed.

pub fn is_valid_transition(from: &MemoryStatus, to: &MemoryStatus) -> bool

Check if a status transition is valid.

pub async fn verify( &self, memory_id: &MemoryId, verifier: AgentId, ) -> Result<(), MemoryError>

Verify a memory by an agent.

Errors

Returns MemoryError::NotFound if the memory does not exist.

pub async fn query( &self, filter: MemoryQuery, ) -> Result<Vec<Memory>, MemoryError>

Query memories by filter.

pub async fn delete(&self, memory_id: &MemoryId) -> Result<(), MemoryError>

Delete a memory.

Errors

Returns MemoryError::NotFound if the memory does not exist.

pub async fn count_by_status( &self, ) -> Result<HashMap<String, usize>, MemoryError>

Count memories by status.