Struct HummockEventHandler

pub struct HummockEventHandler {
    hummock_event_tx: HummockEventSender,
    hummock_event_rx: HummockEventReceiver,
    version_update_rx: UnboundedReceiver<HummockVersionUpdate>,
    read_version_mapping: Arc<RwLock<ReadVersionMappingType>>,
    local_read_version_mapping: HashMap<LocalInstanceId, (TableId, HummockReadVersionRef)>,
    version_update_notifier_tx: Arc<Sender<PinnedVersion>>,
    recent_versions: Arc<ArcSwap<RecentVersions>>,
    uploader: HummockUploader,
    refiller: CacheRefiller,
    last_instance_id: LocalInstanceId,
    metrics: HummockEventHandlerMetrics,
}

Fields

hummock_event_tx: HummockEventSender

hummock_event_rx: HummockEventReceiver

version_update_rx: UnboundedReceiver<HummockVersionUpdate>

read_version_mapping: Arc<RwLock<ReadVersionMappingType>>

local_read_version_mapping: HashMap<LocalInstanceId, (TableId, HummockReadVersionRef)>

A copy of read_version_mapping but owned by event handler

version_update_notifier_tx: Arc<Sender<PinnedVersion>>

recent_versions: Arc<ArcSwap<RecentVersions>>

uploader: HummockUploader

refiller: CacheRefiller

last_instance_id: LocalInstanceId

metrics: HummockEventHandlerMetrics

Implementations

impl HummockEventHandler

pub fn new( version_update_rx: UnboundedReceiver<HummockVersionUpdate>, pinned_version: PinnedVersion, compactor_context: CompactorContext, compaction_catalog_manager_ref: CompactionCatalogManagerRef, sstable_object_id_manager: Arc<SstableObjectIdManager>, state_store_metrics: Arc<HummockStateStoreMetrics>, ) -> Self

fn new_inner( version_update_rx: UnboundedReceiver<HummockVersionUpdate>, sstable_store: SstableStoreRef, state_store_metrics: Arc<HummockStateStoreMetrics>, refill_config: CacheRefillConfig, recent_versions: RecentVersions, buffer_tracker: BufferTracker, spawn_upload_task: SpawnUploadTask, spawn_refill_task: Arc<dyn Fn(Vec<SstDeltaInfo>, CacheRefillContext, PinnedVersion, PinnedVersion) -> JoinHandle<()> + Send + Sync + 'static>, ) -> Self

pub fn version_update_notifier_tx(&self) -> Arc<Sender<PinnedVersion>>

pub fn recent_versions(&self) -> Arc<ArcSwap<RecentVersions>>

pub fn read_version_mapping(&self) -> ReadOnlyReadVersionMapping

pub fn event_sender(&self) -> HummockEventSender

pub fn buffer_tracker(&self) -> &BufferTracker

impl HummockEventHandler

fn for_each_read_version( &self, instances: impl IntoIterator<Item = LocalInstanceId>, f: impl FnMut(LocalInstanceId, &mut HummockReadVersion), )

This function will be performed under the protection of the read_version_mapping read lock, and add write lock on each read_version operation

fn handle_uploaded_sst_inner( &mut self, staging_sstable_info: Arc<StagingSstableInfo>, )

fn handle_sync_epoch( &mut self, sync_table_epochs: Vec<(HummockEpoch, HashSet<TableId>)>, sync_result_sender: Sender<HummockResult<SyncedData>>, )

fn handle_clear( &mut self, notifier: Sender<()>, table_ids: Option<HashSet<TableId>>, )

fn handle_version_update(&mut self, version_payload: HummockVersionUpdate)

fn resolve_version_update_info( pinned_version: PinnedVersion, version_payload: HummockVersionUpdate, sst_delta_infos: Option<&mut Vec<SstDeltaInfo>>, ) -> Option<PinnedVersion>

fn apply_version_update( &mut self, pinned_version: PinnedVersion, new_pinned_version: PinnedVersion, )

impl HummockEventHandler

pub async fn start_hummock_event_handler_worker(self)

fn handle_uploaded_sst(&mut self, sst: Arc<StagingSstableInfo>)

fn handle_hummock_event(&mut self, event: HummockEvent)

Gracefully shutdown if returns true.

fn destroy_read_version(&mut self, instance_id: LocalInstanceId)

fn generate_instance_id(&mut self) -> LocalInstanceId