Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + const MarkersFolder + func CopyMarkers(workingDir string, store string) error + func ExtractIntervalFromTableName(tableName string) model.Interval + type ChunkClient interface + DeleteChunk func(ctx context.Context, userID, chunkID string) error + IsChunkNotFoundErr func(err error) bool + type ChunkEntry struct + Labels labels.Labels + type ChunkEntryCallback func(ChunkEntry) (deleteChunk bool, err error) + type ChunkIterator interface + ForEachChunk func(ctx context.Context, callback ChunkEntryCallback) error + type ChunkRef struct + ChunkID []byte + From model.Time + SeriesID []byte + Through model.Time + UserID []byte + func (c ChunkRef) String() string + type ExpirationChecker interface + DropFromIndex func(ref ChunkEntry, tableEndTime model.Time, now model.Time) bool + Expired func(ref ChunkEntry, now model.Time) (bool, filter.Func) + IntervalMayHaveExpiredChunks func(interval model.Interval, userID string) bool + MarkPhaseFailed func() + MarkPhaseFinished func() + MarkPhaseStarted func() + MarkPhaseTimedOut func() + func NeverExpiringExpirationChecker(_ Limits) ExpirationChecker + func NewExpirationChecker(limits Limits) ExpirationChecker + type IndexProcessor interface + type IntervalFilter struct + Filter filter.Func + Interval model.Interval + type Limits interface + AllByUserID func() map[string]*validation.Limits + DefaultLimits func() *validation.Limits + RetentionPeriod func(userID string) time.Duration + StreamRetention func(userID string) []validation.StreamRetention + type Marker struct + func NewMarker(workingDirectory string, expiration ExpirationChecker, ...) (*Marker, error) + func (t *Marker) MarkForDelete(ctx context.Context, tableName, userID string, indexProcessor IndexProcessor, ...) (bool, bool, error) + type MarkerProcessor interface + Start func(deleteFunc func(ctx context.Context, chunkId []byte) error) + Stop func() + type MarkerStorageWriter interface + Close func() error + Count func() int64 + Put func(chunkID []byte) error + func NewMarkerStorageWriter(workingDir string) (MarkerStorageWriter, error) + type SeriesCleaner interface + CleanupSeries func(userID []byte, lbls labels.Labels) error + type Sweeper struct + func NewSweeper(workingDir string, deleteClient ChunkClient, deleteWorkerCount int, ...) (*Sweeper, error) + func (s *Sweeper) Start() + func (s *Sweeper) Stop() + type TableMarker interface + MarkForDelete func(ctx context.Context, tableName, userID string, indexProcessor IndexProcessor, ...) (bool, bool, error) + type TenantsRetention struct + func NewTenantsRetention(l Limits) *TenantsRetention + func (tr *TenantsRetention) RetentionPeriodFor(userID string, lbs labels.Labels) time.Duration