Enum tikv::server::gc_worker::GcTask

pub enum GcTask {
    Gc {
        region_id: u64,
        start_key: Vec<u8>,
        end_key: Vec<u8>,
        safe_point: TimeStamp,
        callback: Callback<()>,
    },
    GcKeys {
        keys: Vec<Key>,
        safe_point: TimeStamp,
        store_id: u64,
        region_info_provider: Arc<dyn RegionInfoProvider>,
    },
    UnsafeDestroyRange {
        ctx: Context,
        start_key: Key,
        end_key: Key,
        callback: Callback<()>,
    },
    PhysicalScanLock {
        ctx: Context,
        max_ts: TimeStamp,
        start_key: Key,
        limit: usize,
        callback: Callback<Vec<LockInfo>>,
    },
    OrphanVersions {
        wb: RocksWriteBatch,
        id: usize,
    },
}

Variants

Gc

Fields of Gc

region_id: u64start_key: Vec<u8>end_key: Vec<u8>safe_point: TimeStampcallback: Callback<()>

GcKeys

Fields of GcKeys

keys: Vec<Key>safe_point: TimeStampstore_id: u64region_info_provider: Arc<dyn RegionInfoProvider>

UnsafeDestroyRange

Fields of UnsafeDestroyRange

ctx: Contextstart_key: Keyend_key: Keycallback: Callback<()>

PhysicalScanLock

Fields of PhysicalScanLock

ctx: Contextmax_ts: TimeStampstart_key: Keylimit: usizecallback: Callback<Vec<LockInfo>>

OrphanVersions

If GC in compaction filter is enabled, versions on default CF will be handled with DB::delete in write CF’s compaction filter. However if the compaction filter finds the DB is stalled, it will send the task to GC worker to ensure the compaction can be continued.

NOTE: It’s possible that the TiKV instance fails after a compaction result is installed but its orphan versions are not deleted. Those orphan versions will never get cleaned until DefaultCompactionFilter is introduced.

The tracking issue: https://github.com/tikv/tikv/issues/9719.

Fields of OrphanVersions

wb: RocksWriteBatchid: usize

Implementations

impl GcTask

pub fn get_enum_label(&self) -> GcCommandKind

Trait Implementations

impl Display for GcTask

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

Formats the value using the given formatter.

impl<E, RR> Runnable<GcTask> for GcRunner<E, RR> where
    E: Engine,
    RR: RaftStoreRouter<RocksEngine>, 

fn run(&mut self, task: GcTask)

pub fn shutdown(&mut self)