Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + var ErrInvalidIndexKey = errors.New("invalid index key") + 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 ChunkEntryIterator interface + Delete func() error + Entry func() ChunkEntry + Err func() error + Next func() bool + 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, now model.Time) bool + Expired func(ref ChunkEntry, now model.Time) (bool, []model.Interval) + IntervalMayHaveExpiredChunks func(interval model.Interval, userID string) bool + MarkPhaseFailed func() + MarkPhaseFinished func() + MarkPhaseStarted func() + func NewExpirationChecker(limits Limits) ExpirationChecker + type InvalidIndexKeyError struct + HashKey string + RangeKey string + func (e InvalidIndexKeyError) Error() string + func (e InvalidIndexKeyError) Is(target error) bool + type LabelSeriesRangeKey struct + Name []byte + SeriesID []byte + UserID []byte + func (l LabelSeriesRangeKey) String() string + 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, config storage.SchemaConfig, ...) (*Marker, error) + func (t *Marker) MarkForDelete(ctx context.Context, tableName string, db *bbolt.DB) (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 + Cleanup 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 string, db *bbolt.DB) (bool, bool, error) + type TenantsRetention struct + func NewTenantsRetention(l Limits) *TenantsRetention + func (tr *TenantsRetention) RetentionPeriodFor(userID string, lbs labels.Labels) time.Duration
Go to main page