ecat-data 3.0.3

Unified data access traits (RDBMS, Cache, Graph, Search, TSDB)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// Copyright (c) 2026 erik <erik@erik.xyz> — https://erik.xyz
use async_trait::async_trait;
use ecat_errors::Error;

/// Object-storage client abstraction (e.g. S3, MinIO).
#[async_trait]
pub trait StorageClient: Send + Sync {
    /// Upload `data` under `key` in `bucket`.
    async fn put(&self, bucket: &str, key: &str, data: &[u8]) -> Result<(), Error>;

    /// Download the object at `key` in `bucket`.
    async fn get(&self, bucket: &str, key: &str) -> Result<Vec<u8>, Error>;

    /// Delete the object at `key` in `bucket`.
    async fn delete(&self, bucket: &str, key: &str) -> Result<(), Error>;

    /// List object keys in `bucket` under `prefix`.
    async fn list(&self, bucket: &str, prefix: &str) -> Result<Vec<String>, Error>;
}