Struct LocalFsBackend 

pub struct LocalFsBackend { /* private fields */ }

Local filesystem storage backend.

Stores segment files in a namespace-scoped, shard-based directory hierarchy:

{data_dir}/ns_{namespace}/shard_{id}/segment_name.csx

All write operations are atomic (write to .tmp then rename) to prevent partial segment files from being visible to readers.

Implementations

impl LocalFsBackend

pub fn new(data_dir: impl Into<PathBuf>) -> Self

Create a new local filesystem backend rooted at data_dir.

pub fn data_dir(&self) -> &Path

Returns the data directory path.

pub fn resolve(&self, path: &SegmentPath) -> PathBuf

Resolve a SegmentPath to an absolute filesystem path.

Trait Implementations

impl Clone for LocalFsBackend

fn clone(&self) -> LocalFsBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalFsBackend

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

Formats the value using the given formatter.

impl StorageBackend for LocalFsBackend

async fn put_segment(&self, path: &SegmentPath, data: &[u8]) -> Result<()>

Write a complete segment file to storage.

async fn get_segment(&self, path: &SegmentPath) -> Result<Vec<u8>>

Read a complete segment file from storage.

async fn get_range( &self, path: &SegmentPath, offset: u64, length: usize, ) -> Result<Vec<u8>>

Read a byte range from a segment file.

async fn delete_segment(&self, path: &SegmentPath) -> Result<()>

Delete a segment file from storage.

async fn list_segments( &self, namespace: &NamespaceId, shard_id: &ShardId, ) -> Result<Vec<SegmentPath>>

List all segment files in a namespace/shard.

async fn exists(&self, path: &SegmentPath) -> Result<bool>

Check whether a segment file exists.