Struct glommio::io::DmaStreamReaderBuilder

pub struct DmaStreamReaderBuilder { /* fields omitted */ }

Builds a DmaStreamReader, allowing linear access to a Direct I/O DmaFile

Implementations

impl DmaStreamReaderBuilder

#[must_use = "The builder must be built to be useful"]pub fn new(file: DmaFile) -> DmaStreamReaderBuilder

Creates a new DmaStreamReaderBuilder, given a DmaFile

Various properties can be set by using its with methods.

A DmaStreamReader can later be constructed from it by calling build

Examples

use glommio::io::{DmaFile, DmaStreamReaderBuilder};
use glommio::LocalExecutor;

let ex = LocalExecutor::make_default();
ex.run(async {
    let file = DmaFile::open("myfile.txt").await.unwrap();
    let _reader = DmaStreamReaderBuilder::new(file).build();
});

pub fn with_start_pos(self, start: u64) -> Self

Define a starting position.

Reads from the DmaStreamReader will start from this position

pub fn with_end_pos(self, end: u64) -> Self

Define an end position.

Reads from the DmaStreamReader will end at this position even if the file is larger.

pub fn with_read_ahead(self, read_ahead: usize) -> Self

Define the number of read-ahead buffers that will be used by the DmaStreamReader

Higher read-ahead numbers mean more parallelism but also more memory usage.

pub fn with_buffer_size(self, buffer_size: usize) -> Self

Define the buffer size that will be used by the DmaStreamReader

pub fn build(self) -> DmaStreamReader

Builds a DmaStreamReader with the properties defined by this DmaStreamReaderBuilder

Trait Implementations

impl Clone for DmaStreamReaderBuilder

fn clone(&self) -> DmaStreamReaderBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DmaStreamReaderBuilder

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

Formats the value using the given formatter.