deletion

type ApplyStorageUpdatesFunc func(ctx context.Context, iterator StorageUpdatesIterator) error

type Chunk interface {
	GetFrom() model.Time
	GetThrough() model.Time
	GetFingerprint() uint64
	GetChecksum() uint32
	GetSize() uint32
	GetEntriesCount() uint32
}

type CompactorClient interface {
	GetAllDeleteRequestsForUser(ctx context.Context, userID string, forQuerytimeFiltering bool, timeRange *TimeRange) ([]deletionproto.DeleteRequest, error)
	GetCacheGenerationNumber(ctx context.Context, userID string) (string, error)
	Name() string
	Stop()
}

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

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

type DeleteRequestsClient interface {
	GetAllDeleteRequestsForUser(ctx context.Context, userID string, forQuerytimeFiltering bool, timeRange *TimeRange) ([]deletionproto.DeleteRequest, error)
	Stop()
}

type DeleteRequestsKind string

type DeleteRequestsManager struct {
	HSModeEnabled bool
	// contains filtered or unexported fields
}

type DeleteRequestsStore interface {
	AddDeleteRequest(ctx context.Context, userID, query string, startTime, endTime model.Time, shardByInterval time.Duration) (string, error)

	GetAllRequests(ctx context.Context) ([]deletionproto.DeleteRequest, error)
	GetAllDeleteRequestsForUser(ctx context.Context, userID string, forQuerytimeFiltering bool, timeRange *TimeRange) ([]deletionproto.DeleteRequest, error)
	RemoveDeleteRequest(ctx context.Context, userID string, requestID string) error
	GetDeleteRequest(ctx context.Context, userID, requestID string) (deletionproto.DeleteRequest, error)
	GetCacheGenerationNumber(ctx context.Context, userID string) (string, error)
	MergeShardedRequests(ctx context.Context) error

	// ToDo(Sandeep): To keep changeset smaller, below 2 methods treat a single shard as individual request. This can be refactored later in a separate PR.
	MarkShardAsProcessed(ctx context.Context, req deletionproto.DeleteRequest) error
	GetUnprocessedShards(ctx context.Context) ([]deletionproto.DeleteRequest, error)

	Stop()
	// contains filtered or unexported methods
}

type DeleteRequestsStoreDBType string

type DeleteRequestsStoreOption func(c *deleteRequestsClient)

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

type GetChunkClientForTableFunc func(table string) (client.Client, error)

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

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

type Limits interface {
	DeletionMode(userID string) string
	RetentionPeriod(userID string) time.Duration
	StreamRetention(userID string) []validation.StreamRetention
}

type StorageUpdatesIterator interface {
	Next() bool
	UserID() string
	TableName() string
	Err() error
	ForEachSeries(callback func(labels string, rebuiltChunks map[string]Chunk, chunksToDeIndex []string) error) error
}

type Table interface {
	GetUserIndex(userID string) (retention.SeriesIterator, error)
}

type TableIteratorFunc func(ctx context.Context, callback func(string, Table) error) (err error)

type TablesManager interface {
	ApplyStorageUpdates(ctx context.Context, iterator StorageUpdatesIterator) error
	IterateTables(ctx context.Context, callback func(string, Table) error) (err error)
}

type TimeRange struct {
	Start, End model.Time
}