Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + type Compactor struct + DeleteRequestsHandler *deletion.DeleteRequestHandler + func NewCompactor(cfg Config, storageConfig storage.Config, ...) (*Compactor, error) + func (c *Compactor) CompactTable(ctx context.Context, tableName string, applyRetention bool) error + func (c *Compactor) OnRingInstanceHeartbeat(_ *ring.BasicLifecycler, _ *ring.Desc, _ *ring.InstanceDesc) + func (c *Compactor) OnRingInstanceRegister(_ *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, ...) (ring.InstanceState, ring.Tokens) + func (c *Compactor) OnRingInstanceStopping(_ *ring.BasicLifecycler) + func (c *Compactor) OnRingInstanceTokens(_ *ring.BasicLifecycler, _ ring.Tokens) + func (c *Compactor) RunCompaction(ctx context.Context, applyRetention bool) error + func (c *Compactor) ServeHTTP(w http.ResponseWriter, req *http.Request) + type Config struct + ApplyRetentionInterval time.Duration + CompactionInterval time.Duration + CompactorRing util.RingConfig + DeleteRequestCancelPeriod time.Duration + MaxCompactionParallelism int + RetentionDeleteDelay time.Duration + RetentionDeleteWorkCount int + RetentionEnabled bool + SharedStoreKeyPrefix string + SharedStoreType string + WorkingDirectory string + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error
Go to main page