Struct CasyncBlockReader 

pub struct CasyncBlockReader<S> { /* private fields */ }

Implementations

impl<S> CasyncBlockReader<S>

where S: CasyncChunkStore,

pub async fn open<I>( index_source: I, chunk_store: S, config: CasyncReaderConfig, ) -> GibbloxResult<Self>

where I: CasyncIndexSource,

pub fn index(&self) -> &CasyncIndex

pub fn index_digest(&self) -> CasyncChunkId

pub fn chunks_verified(&self) -> u64

Trait Implementations

impl<S> BlockReader for CasyncBlockReader<S>

where S: CasyncChunkStore,

fn block_size(&self) -> u32

Logical block size in bytes.

fn total_blocks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = GibbloxResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Total number of logical blocks available.

fn write_identity(&self, out: &mut dyn Write) -> Result

Write a stable, canonical identity string for this block reader.

fn read_blocks<'life0, 'life1, 'async_trait>( &'life0 self, lba: u64, buf: &'life1 mut [u8], ctx: ReadContext, ) -> Pin<Box<dyn Future<Output = GibbloxResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read one or more blocks starting at lba into buf.