Enum tikv::server::gc_worker::GcTask

[−] Show declaration

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

[−] Show fields

Fields of Gc

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

GcKeys

[−] Show fields

Fields of GcKeys

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

UnsafeDestroyRange

[−] Show fields

Fields of UnsafeDestroyRange

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

PhysicalScanLock

[−] Show fields

Fields of PhysicalScanLock

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

OrphanVersions

[−] Expand description

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.

[−] Show fields

Fields of OrphanVersions

wb: RocksWriteBatchid: usize

Implementations

impl GcTask[−]

pub fn get_enum_label(&self) -> GcCommandKind

Trait Implementations

impl Display for GcTask[+]

[+] Show hidden undocumented items

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>, [+]

[+] Show hidden undocumented items

fn run(&mut self, task: GcTask)

pub fn shutdown(&mut self)