Struct StorageLayer 

pub struct StorageLayer {
    pub database: Arc<Database>,
    pub redis: Arc<RedisPool>,
    pub files: Arc<FileStorage>,
    pub vector: Option<Arc<VectorStoreBackend>>,
    pub redis_status: DependencyStatus,
    pub vector_status: DependencyStatus,
}

Main storage layer that orchestrates all storage backends

Fields

database: Arc<Database>

Database connection pool

redis: Arc<RedisPool>

Redis connection pool

files: Arc<FileStorage>

File storage backend

vector: Option<Arc<VectorStoreBackend>>

Vector database client (optional) Note: Using concrete type instead of trait object for now

redis_status: DependencyStatus

Status of the Redis dependency after init.

vector_status: DependencyStatus

Status of the vector DB dependency after init.

Implementations

impl StorageLayer

pub async fn new(config: &StorageConfig) -> Result<Self>

Create a new storage layer.

For each optional dependency:

• if enabled is false (or the section is absent), the dependency is treated as Disabled and a no-op fallback is used,
• if enabled is true and init succeeds, status is Healthy,
• if enabled is true, init fails, and allow_degraded is false, the call returns Err so startup fails loudly,
• if enabled is true, init fails, and allow_degraded is true, the error is logged at error! level and the dependency status is set to Degraded while the gateway keeps running.

pub async fn migrate(&self) -> Result<()>

Run database migrations

pub async fn health_check(&self) -> Result<StorageHealthStatus>

Health check for all storage backends

pub async fn close(&self) -> Result<()>

Close all connections

pub fn db(&self) -> &Database

Get database pool

pub fn redis(&self) -> &RedisPool

Get Redis pool

pub fn files(&self) -> &FileStorage

Get file storage

pub fn vector(&self) -> Option<&VectorStoreBackend>

Get vector store (if available)

pub async fn redis_conn(&self) -> Result<RedisConnection>

Get a Redis connection

pub async fn store_file(&self, filename: &str, content: &[u8]) -> Result<String>

Store file and return file ID

pub async fn get_file(&self, file_id: &str) -> Result<Vec<u8>>

Retrieve file content

pub async fn delete_file(&self, file_id: &str) -> Result<()>

Delete file

pub async fn store_embeddings( &self, id: &str, embeddings: &[f32], metadata: Option<Value>, ) -> Result<()>

Store vector embeddings

pub async fn search_similar( &self, query_vector: &[f32], limit: usize, threshold: Option<f32>, ) -> Result<Vec<SearchResult>>

Search similar vectors

pub async fn cache_get(&self, key: &str) -> Result<Option<String>>

Cache operations

pub async fn cache_set( &self, key: &str, value: &str, ttl: Option<u64>, ) -> Result<()>

Set cache value with optional TTL

pub async fn cache_delete(&self, key: &str) -> Result<()>

Delete cache key

pub async fn cache_exists(&self, key: &str) -> Result<bool>

Check if cache key exists

pub async fn cache_mget(&self, keys: &[String]) -> Result<Vec<Option<String>>>

Batch cache operations

pub async fn cache_mset( &self, pairs: &[(String, String)], ttl: Option<u64>, ) -> Result<()>

Set multiple cache values with optional TTL

pub async fn list_push(&self, key: &str, value: &str) -> Result<()>

List operations Push value to list

pub async fn list_pop(&self, key: &str) -> Result<Option<String>>

Pop value from list

pub async fn list_length(&self, key: &str) -> Result<usize>

Get list length

pub async fn set_add(&self, key: &str, member: &str) -> Result<()>

Set operations Add member to set

pub async fn set_remove(&self, key: &str, member: &str) -> Result<()>

Remove member from set

pub async fn set_members(&self, key: &str) -> Result<Vec<String>>

Get all members of set

pub async fn hash_set(&self, key: &str, field: &str, value: &str) -> Result<()>

Hash operations Set hash field value

pub async fn hash_get(&self, key: &str, field: &str) -> Result<Option<String>>

Get hash field value

pub async fn hash_delete(&self, key: &str, field: &str) -> Result<()>

Delete hash field

pub async fn hash_get_all(&self, key: &str) -> Result<HashMap<String, String>>

Get all hash fields and values

pub async fn publish(&self, channel: &str, message: &str) -> Result<()>

Pub/Sub operations

pub async fn subscribe(&self, channels: &[String]) -> Result<Subscription>

Subscribe to Redis channels Subscribe to Redis channels for pub/sub messaging

Trait Implementations

impl Clone for StorageLayer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StorageLayer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.