Struct SchedulerConfig

pub struct SchedulerConfig {
    pub io_buffer_size_bytes: u64,
}

Fields

io_buffer_size_bytes: u64

the # of bytes that can be buffered but not yet requested. This controls back pressure. If data is not processed quickly enough then this buffer will fill up and the I/O loop will pause until the buffer is drained.

Implementations

impl SchedulerConfig

pub fn default_for_testing() -> Self

Big enough for unit testing

pub fn max_bandwidth(store: &ObjectStore) -> Self

Configuration that should generally maximize bandwidth (not trying to save RAM at all). We assume a max page size of 32MiB and then allow 32MiB per I/O thread

Trait Implementations

impl Clone for SchedulerConfig

fn clone(&self) -> SchedulerConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerConfig

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

Formats the value using the given formatter.

impl Copy for SchedulerConfig