Struct FileChunkedIO 

pub struct FileChunkedIO { /* private fields */ }

File-based chunked I/O implementation.

Implementations

impl FileChunkedIO

pub async fn new<P: AsRef<Path>>( path: P, strategy: ChunkStrategy, ) -> Result<Self>

Create a new file-based chunked I/O.

pub async fn open_read(&mut self) -> Result<()>

Open the file for reading.

pub async fn open_write(&mut self) -> Result<()>

Open the file for writing.

pub fn with_direct_io(self, enable: bool) -> Self

Enable direct I/O (platform-dependent).

Trait Implementations

impl ChunkedIO for FileChunkedIO

fn read_chunk<'life0, 'life1, 'async_trait>( &'life0 mut self, descriptor: &'life1 ChunkDescriptor, ) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>

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

Read a chunk at the specified offset.

fn write_chunk<'life0, 'life1, 'async_trait>( &'life0 mut self, descriptor: &'life1 ChunkDescriptor, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Write a chunk at the specified offset.

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

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

Get the total size of the data.

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Flush any pending writes.