Struct UploaderImm

pub(super) struct UploaderImm {
    inner: ImmutableMemtable,
    size_guard: GenericGauge<AtomicU64>,
}

Fields

inner: ImmutableMemtable

size_guard: GenericGauge<AtomicU64>

Implementations

impl UploaderImm

pub(super) fn new(imm: ImmutableMemtable, context: &UploaderContext) -> Self

Methods from Deref<Target = ImmutableMemtable>

pub fn filter<R, B>(&self, table_id: TableId, table_key_range: &R) -> bool

where R: RangeBounds<TableKey<B>>, B: AsRef<[u8]>,

pub fn table_id(&self) -> TableId

pub fn min_epoch(&self) -> HummockEpoch

pub fn max_epoch(&self) -> HummockEpoch

pub fn key_count(&self) -> usize

pub fn value_count(&self) -> usize

pub fn has_old_value(&self) -> bool

pub fn get( &self, table_key: TableKey<&[u8]>, read_epoch: HummockEpoch, _read_options: &ReadOptions, ) -> Option<(HummockValue<Bytes>, EpochWithGap)>

pub fn range_exists(&self, table_key_range: &TableKeyRange) -> bool

pub fn start_table_key(&self) -> TableKey<&[u8]>

pub fn end_table_key(&self) -> TableKey<&[u8]>

pub fn raw_largest_key(&self) -> &TableKey<Bytes>

pub fn start_user_key(&self) -> UserKey<&[u8]>

return inclusive left endpoint, which means that all data in this batch should be larger or equal than this key.

pub fn size(&self) -> usize

pub(crate) fn old_values(&self) -> Option<&SharedBufferBatchOldValues>

pub fn batch_id(&self) -> SharedBufferBatchId

pub fn epochs(&self) -> &Vec<HummockEpoch>

Trait Implementations

impl Debug for UploaderImm

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

Formats the value using the given formatter.

impl Deref for UploaderImm

type Target = SharedBufferBatch

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Drop for UploaderImm

fn drop(&mut self)

Executes the destructor for this type.