Enum HummockEvent

pub enum HummockEvent {
    BufferMayFlush,
    SyncEpoch {
        sync_result_sender: Sender<HummockResult<SyncedData>>,
        sync_table_epochs: Vec<(HummockEpoch, HashSet<TableId>)>,
    },
    Clear(Sender<()>, Option<HashSet<TableId>>),
    Shutdown,
    ImmToUploader {
        instance_id: SharedBufferBatchId,
        imm: ImmutableMemtable,
    },
    StartEpoch {
        epoch: HummockEpoch,
        table_ids: HashSet<TableId>,
    },
    InitEpoch {
        instance_id: LocalInstanceId,
        init_epoch: HummockEpoch,
    },
    LocalSealEpoch {
        instance_id: LocalInstanceId,
        next_epoch: HummockEpoch,
        opts: SealCurrentEpochOptions,
    },
    FlushEvent(Sender<()>),
    RegisterReadVersion {
        table_id: TableId,
        new_read_version_sender: Sender<(HummockReadVersionRef, LocalInstanceGuard)>,
        is_replicated: bool,
        vnodes: Arc<Bitmap>,
    },
    DestroyReadVersion {
        instance_id: LocalInstanceId,
    },
    GetMinUncommittedSstId {
        result_tx: Sender<Option<HummockSstableObjectId>>,
    },
}

Variants

BufferMayFlush

Notify that we may flush the shared buffer.

SyncEpoch

An epoch is going to be synced. Once the event is processed, there will be no more flush task on this epoch. Previous concurrent flush task join handle will be returned by the join handle sender.

Fields

sync_result_sender: Sender<HummockResult<SyncedData>>

sync_table_epochs: Vec<(HummockEpoch, HashSet<TableId>)>

Clear(Sender<()>, Option<HashSet<TableId>>)

Clear shared buffer and reset all states

Shutdown

ImmToUploader

Fields

instance_id: SharedBufferBatchId

imm: ImmutableMemtable

StartEpoch

Fields

epoch: HummockEpoch

table_ids: HashSet<TableId>

InitEpoch

Fields

instance_id: LocalInstanceId

init_epoch: HummockEpoch

LocalSealEpoch

Fields

instance_id: LocalInstanceId

next_epoch: HummockEpoch

opts: SealCurrentEpochOptions

FlushEvent(Sender<()>)

Flush all previous event. When all previous events has been consumed, the event handler will notify

RegisterReadVersion

Fields

table_id: TableId

new_read_version_sender: Sender<(HummockReadVersionRef, LocalInstanceGuard)>

is_replicated: bool

vnodes: Arc<Bitmap>

DestroyReadVersion

Fields

instance_id: LocalInstanceId

GetMinUncommittedSstId

Fields

result_tx: Sender<Option<HummockSstableObjectId>>

Implementations

impl HummockEvent

fn to_debug_string(&self) -> String

Trait Implementations

impl Debug for HummockEvent

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

Formats the value using the given formatter.