Struct ShardedBlockStore 

pub struct ShardedBlockStore { /* private fields */ }

Sharded block store for parallel I/O

Implementations

impl ShardedBlockStore

pub fn new() -> Self

Create a new sharded block store with default settings

pub fn with_shards(shard_count: usize) -> Self

Create with specific number of shards

pub fn write_block(&self, file_id: u64, data: &[u8]) -> Result<ShardedBlockRef>

Write a block for a specific file

pub fn write_block_with_compression( &self, file_id: u64, data: &[u8], compression: BlockCompression, ) -> Result<ShardedBlockRef>

Write a block with specific compression

pub fn read_block(&self, shard_ref: &ShardedBlockRef) -> Result<Vec<u8>>

Read a block

pub fn add_ref(&self, shard_ref: &ShardedBlockRef)

Increment reference count

pub fn release_ref(&self, shard_ref: &ShardedBlockRef) -> bool

Decrement reference count

pub fn stats(&self) -> ShardedBlockStoreStats

Get aggregate statistics

Trait Implementations

impl Default for ShardedBlockStore

fn default() -> Self

Returns the “default value” for a type.