compactor

Documentation

Index

• type Compactor
  • func NewCompactor(compactorCfg Config, storageCfg cortex_tsdb.Config, logger log.Logger, ...) (*Compactor, error)
  • func (c *Compactor) Shutdown()
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)

Types

type Compactor

type Compactor struct {
	// contains filtered or unexported fields
}

Compactor is a multi-tenant TSDB blocks compactor based on Thanos.

func NewCompactor

func NewCompactor(compactorCfg Config, storageCfg cortex_tsdb.Config, logger log.Logger, registerer prometheus.Registerer) (*Compactor, error)

NewCompactor makes a new Compactor.

func (*Compactor) Shutdown

func (c *Compactor) Shutdown()

Shutdown the compactor and waits until done. This may take some time if there's a on-going compaction.

type Config

type Config struct {
	BlockRanges          cortex_tsdb.DurationList `yaml:"block_ranges"`
	BlockSyncConcurrency int                      `yaml:"block_sync_concurrency"`
	ConsistencyDelay     time.Duration            `yaml:"consistency_delay"`
	DataDir              string                   `yaml:"data_dir"`
	CompactionInterval   time.Duration            `yaml:"compaction_interval"`
	CompactionRetries    int                      `yaml:"compaction_retries"`
	// contains filtered or unexported fields
}

Config holds the Compactor config.

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers the Compactor flags.