ailake-store 0.0.11

Unified object storage abstraction (S3, GCS, Azure, local) for AI-Lake
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

// SPDX-License-Identifier: MIT OR Apache-2.0
use std::ops::Range;

use ailake_core::AilakeResult;
use async_trait::async_trait;
use bytes::Bytes;

/// Unified object storage abstraction.
/// All methods are async; implementations cover local filesystem and cloud (Phase 2).
#[async_trait]
pub trait Store: Send + Sync {
    async fn get(&self, path: &str) -> AilakeResult<Bytes>;

    /// Partial read — critical for S3 HNSW footer reads.
    async fn get_range(&self, path: &str, range: Range<u64>) -> AilakeResult<Bytes>;

    async fn put(&self, path: &str, data: Bytes) -> AilakeResult<()>;

    async fn list(&self, prefix: &str) -> AilakeResult<Vec<String>>;

    async fn file_size(&self, path: &str) -> AilakeResult<u64>;

    async fn exists(&self, path: &str) -> AilakeResult<bool>;

    async fn delete(&self, path: &str) -> AilakeResult<()>;
}