compactor

Documentation

Index

• type Compactor
  • func New(cfg Config, store storage.Store, overrides *overrides.Overrides) (*Compactor, error)
  • func (c *Compactor) BlockRetentionForTenant(tenantID string) time.Duration
  • func (c *Compactor) Combine(objA []byte, objB []byte, dataEncoding string) ([]byte, bool)
  • func (c *Compactor) Owns(hash string) bool
• type Config
  • func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

Types

type Compactor

type Compactor struct {
	services.Service

	Ring *ring.Ring
	// contains filtered or unexported fields
}

func New

func New(cfg Config, store storage.Store, overrides *overrides.Overrides) (*Compactor, error)

New makes a new Compactor.

func (*Compactor) BlockRetentionForTenant

func (c *Compactor) BlockRetentionForTenant(tenantID string) time.Duration

BlockRetentionForTenant implements CompactorOverrides

func (*Compactor) Combine

func (c *Compactor) Combine(objA []byte, objB []byte, dataEncoding string) ([]byte, bool)

Combine implements common.ObjectCombiner

func (*Compactor) Owns

func (c *Compactor) Owns(hash string) bool

Owns implements CompactorSharder

type Config

type Config struct {
	ShardingRing    cortex_compactor.RingConfig `yaml:"ring,omitempty"`
	Compactor       tempodb.CompactorConfig     `yaml:"compaction"`
	OverrideRingKey string                      `yaml:"override_ring_key"`
}

func (*Config) RegisterFlagsAndApplyDefaults

func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

RegisterFlagsAndApplyDefaults registers the flags.