risingwave_storage::hummock::compactor::compactor_runner

Function compact_with_agent

source 
pub async fn compact_with_agent(
    compactor_context: CompactorContext,
    compact_task: CompactTask,
    shutdown_rx: Receiver<()>,
    object_id_getter: Box<dyn GetObjectId>,
    compaction_catalog_agent_ref: CompactionCatalogAgentRef,
) -> ((CompactTask, HashMap<u32, TableStats>, HashMap<HummockSstableObjectId, u64>), Option<MemoryTracker>)
Expand description

Handles a compaction task and reports its status to hummock manager. Always return Ok and let hummock manager handle errors.