Struct ResilientIndexBackend 

pub struct ResilientIndexBackend<I: IndexBackend> {
    inner: I,
    config: StorageResilienceConfig,
    breaker: Mutex<CircuitBreaker>,
    backend_name: &'static str,
}

Index backend wrapper with circuit breaker and retry protection.

Fields

inner: I

config: StorageResilienceConfig

breaker: Mutex<CircuitBreaker>

backend_name: &'static str

Implementations

impl<I: IndexBackend> ResilientIndexBackend<I>

pub fn new( inner: I, config: StorageResilienceConfig, backend_name: &'static str, ) -> Self

Creates a new resilient index backend wrapper.

fn execute<T, F>(&self, operation: &'static str, call: F) -> Result<T>

where F: FnMut() -> Result<T>,

fn check_circuit_breaker(&self, operation: &'static str) -> Option<Error>

Checks circuit breaker and returns error if open.

fn handle_success<T>(&self, operation: &'static str, value: T) -> T

Handles successful operation result.

fn handle_error( &self, operation: &'static str, err: Error, attempts: u32, max_attempts: u32, ) -> Result<Option<Error>>

Handles operation error. Returns Ok(Some(err)) to continue retrying, Err to stop.

fn apply_retry_backoff(&self, attempts: u32)

Applies retry backoff delay if configured.

fn record_metrics( backend: &'static str, operation: &'static str, status: &'static str, state: u8, )

fn record_circuit_trip(backend: &'static str, operation: &'static str)

Records metrics and logs when circuit breaker trips.

fn log_retry(backend: &'static str, operation: &'static str)

Records metrics for retry attempts.

Trait Implementations

impl<I: IndexBackend> IndexBackend for ResilientIndexBackend<I>

fn index(&self, memory: &Memory) -> Result<()>

Indexes a memory for full-text search.

fn remove(&self, id: &MemoryId) -> Result<bool>

Removes a memory from the index.

fn search( &self, query: &str, filter: &SearchFilter, limit: usize, ) -> Result<Vec<(MemoryId, f32)>>

Searches for memories matching a text query.

fn reindex(&self, memories: &[Memory]) -> Result<()>

Re-indexes all memories.

fn clear(&self) -> Result<()>

Clears the entire index.

fn list_all( &self, filter: &SearchFilter, limit: usize, ) -> Result<Vec<(MemoryId, f32)>>

Lists all indexed memories, optionally filtered.

fn get_memory(&self, id: &MemoryId) -> Result<Option<Memory>>

Retrieves a memory by ID.

fn get_memories_batch(&self, ids: &[MemoryId]) -> Result<Vec<Option<Memory>>>

Retrieves multiple memories by their IDs in a single batch query.