rsearch-storage 0.2.0

Object storage backends for rSearch: local filesystem, S3/MinIO, and node-replicated
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::sync::Arc;

use rsearch_common::config::StorageConfig;

use crate::error::{StorageError, StorageResult};
use crate::fs::FsStorage;
use crate::s3::S3Storage;
use crate::storage::Storage;

/// Build the storage backend selected by configuration.
pub async fn from_config(cfg: &StorageConfig) -> StorageResult<Arc<dyn Storage>> {
    match cfg.backend.as_str() {
        "fs" => Ok(Arc::new(FsStorage::new(cfg.root.clone()))),
        "s3" => Ok(Arc::new(S3Storage::from_config(cfg).await?)),
        other => Err(StorageError::Backend {
            key: String::new(),
            message: format!(
                "unknown storage backend '{other}' (expected fs, s3, or replicated — \
                 replicated is constructed by the server, not this factory)"
            ),
        }),
    }
}