Struct BufferTracker

pub struct BufferTracker {
    flush_threshold: usize,
    min_batch_flush_size: usize,
    global_buffer: Arc<MemoryLimiter>,
    global_upload_task_size: GenericGauge<AtomicU64>,
}

Fields

flush_threshold: usize

min_batch_flush_size: usize

global_buffer: Arc<MemoryLimiter>

global_upload_task_size: GenericGauge<AtomicU64>

Implementations

impl BufferTracker

pub fn from_storage_opts( config: &StorageOpts, global_upload_task_size: GenericGauge<AtomicU64>, ) -> Self

fn new( capacity: usize, flush_threshold: usize, global_upload_task_size: GenericGauge<AtomicU64>, min_batch_flush_size: usize, ) -> Self

pub fn for_test() -> Self

pub fn get_buffer_size(&self) -> usize

pub fn get_memory_limiter(&self) -> &Arc<MemoryLimiter>

pub fn global_upload_task_size(&self) -> &GenericGauge<AtomicU64>

pub fn need_flush(&self) -> bool

Return true when the buffer size minus current upload task size is still greater than the flush threshold.

pub fn need_more_flush(&self, curr_batch_flush_size: usize) -> bool

Trait Implementations

impl Clone for BufferTracker

fn clone(&self) -> BufferTracker

Returns a copy of the value.

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

Performs copy-assignment from source.