Struct DynamicLevelSelectorCore 

pub struct DynamicLevelSelectorCore {
    config: Arc<CompactionConfig>,
    developer_config: Arc<CompactionDeveloperConfig>,
}

Fields

config: Arc<CompactionConfig>

developer_config: Arc<CompactionDeveloperConfig>

Implementations

impl DynamicLevelSelectorCore

pub fn new( config: Arc<CompactionConfig>, developer_config: Arc<CompactionDeveloperConfig>, ) -> Self

pub fn get_config(&self) -> &CompactionConfig

fn create_compaction_picker( &self, picker_info: &PickerInfo, overlap_strategy: Arc<dyn OverlapStrategy>, compaction_task_validator: Arc<CompactionTaskValidator>, ) -> Box<dyn CompactionPicker>

pub fn calculate_level_base_size(&self, levels: &Levels) -> SelectContext

calculate_level_base_size calculate base level and the base size of LSM tree build for current dataset. In other words, level_max_bytes is our compaction goal which shall reach. This algorithm refers to the implementation in https://github.com/facebook/rocksdb/blob/v7.2.2/db/version_set.cc#L3706

pub(crate) fn get_priority_levels( &self, levels: &Levels, handlers: &[LevelHandler], ) -> SelectContext

pub fn compact_pending_bytes_needed(&self, levels: &Levels) -> u64

compact_pending_bytes_needed calculates the number of compact bytes needed to balance the LSM Tree from the current state of each level in the LSM Tree in combination with compaction_config This algorithm refers to the implementation in https://github.com/facebook/rocksdb/blob/main/db/version_set.cc#L3141

pub fn compact_pending_bytes_needed_with_ctx( &self, levels: &Levels, ctx: &SelectContext, ) -> u64