Struct Compactor 

pub struct Compactor { /* private fields */ }

Background compactor for time-series chunks

Implementations

impl Compactor

pub fn new() -> Self

Create a new compactor with default configuration

pub fn with_config(config: CompactionConfig) -> Self

Create a new compactor with custom configuration

pub async fn start(&self, store: Arc<ColumnarStore>) -> TsdbResult<()>

Start background compaction task

Runs compaction at configured intervals until stopped.

pub fn stop(&self)

Stop background compaction

pub async fn compact_once(&self, store: &ColumnarStore) -> TsdbResult<()>

Run a single compaction cycle

pub fn stats(&self) -> TsdbResult<CompactionStats>

Get compaction statistics

pub fn reset_stats(&self) -> TsdbResult<()>

Reset compaction statistics

pub fn is_running(&self) -> bool

Check if compactor is running

Trait Implementations

impl Debug for Compactor

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

Formats the value using the given formatter.

impl Default for Compactor

fn default() -> Self

Returns the “default value” for a type.