Struct BufferScheduler 

pub struct BufferScheduler { /* private fields */ }

An implementation of EncodingsIo that serves data from an in-memory buffer

Implementations

impl BufferScheduler

pub fn new(data: Bytes) -> Self

Trait Implementations

impl Debug for BufferScheduler

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

Formats the value using the given formatter.

impl EncodingsIo for BufferScheduler

fn submit_request( &self, ranges: Vec<Range<u64>>, _priority: u64, ) -> BoxFuture<'static, Result<Vec<Bytes>>>

Submit an I/O request

fn submit_single( &self, range: Range<u64>, priority: u64, ) -> BoxFuture<'static, Result<Bytes>>

Submit an I/O request with a single range

fn with_bypass_backpressure(&self) -> Option<Arc<dyn EncodingsIo>>

Returns a version of this I/O service that bypasses backpressure for all requests.

fn with_io_stats( &self, _stats: Arc<dyn IoStatsRecorder>, ) -> Option<Arc<dyn EncodingsIo>>

Returns a version of this I/O service that additionally records the I/O it performs into stats, on top of any global accounting. This is the seam used to measure exact per-scope (e.g. per-query) I/O without re-opening files: wrap a reader’s I/O service, perform the reads, then inspect the recorder.