Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + var ErrDeleteRequestNotFound = errors.New("could not find matching delete requests") + func TenantMiddleware(limits Limits, next http.Handler) http.Handler + type CompactorClient interface + GetAllDeleteRequestsForUser func(ctx context.Context, userID string) ([]DeleteRequest, error) + GetCacheGenerationNumber func(ctx context.Context, userID string) (string, error) + Name func() string + Stop func() + type DeleteRequest struct + CreatedAt model.Time + DeletedLines int32 + EndTime model.Time + Metrics *deleteRequestsManagerMetrics + Query string + RequestID string + SequenceNum int64 + StartTime model.Time + Status DeleteRequestStatus + UserID string + func (d *DeleteRequest) FilterFunction(lbls labels.Labels) (filter.Func, error) + func (d *DeleteRequest) IsDeleted(entry retention.ChunkEntry) (bool, filter.Func) + func (d *DeleteRequest) SetQuery(logQL string) error + type DeleteRequestClientMetrics struct + func NewDeleteRequestClientMetrics(r prometheus.Registerer) *DeleteRequestClientMetrics + type DeleteRequestHandler struct + func NewDeleteRequestHandler(deleteStore DeleteRequestsStore, maxInterval time.Duration, ...) *DeleteRequestHandler + func (dm *DeleteRequestHandler) AddDeleteRequestHandler(w http.ResponseWriter, r *http.Request) + func (dm *DeleteRequestHandler) CancelDeleteRequestHandler(w http.ResponseWriter, r *http.Request) + func (dm *DeleteRequestHandler) GetAllDeleteRequestsHandler(w http.ResponseWriter, r *http.Request) + func (dm *DeleteRequestHandler) GetCacheGenerationNumberHandler(w http.ResponseWriter, r *http.Request) + type DeleteRequestStatus string + const DeleteRequestsTableName + const StatusProcessed + const StatusReceived + type DeleteRequestsClient interface + GetAllDeleteRequestsForUser func(ctx context.Context, userID string) ([]DeleteRequest, error) + Stop func() + func NewDeleteRequestsClient(compactorClient CompactorClient, ...) (DeleteRequestsClient, error) + func NewPerTenantDeleteRequestsClient(c DeleteRequestsClient, l Limits) DeleteRequestsClient + type DeleteRequestsManager struct + func NewDeleteRequestsManager(store DeleteRequestsStore, deleteRequestCancelPeriod time.Duration, ...) *DeleteRequestsManager + func (d *DeleteRequestsManager) DropFromIndex(_ retention.ChunkEntry, _ model.Time, _ model.Time) bool + func (d *DeleteRequestsManager) Expired(ref retention.ChunkEntry, _ model.Time) (bool, filter.Func) + func (d *DeleteRequestsManager) IntervalMayHaveExpiredChunks(_ model.Interval, userID string) bool + func (d *DeleteRequestsManager) MarkPhaseFailed() + func (d *DeleteRequestsManager) MarkPhaseFinished() + func (d *DeleteRequestsManager) MarkPhaseStarted() + func (d *DeleteRequestsManager) MarkPhaseTimedOut() + func (d *DeleteRequestsManager) Stop() + type DeleteRequestsStore interface + AddDeleteRequestGroup func(ctx context.Context, req []DeleteRequest) ([]DeleteRequest, error) + GetAllDeleteRequestsForUser func(ctx context.Context, userID string) ([]DeleteRequest, error) + GetCacheGenerationNumber func(ctx context.Context, userID string) (string, error) + GetDeleteRequestGroup func(ctx context.Context, userID, requestID string) ([]DeleteRequest, error) + GetDeleteRequestsByStatus func(ctx context.Context, status DeleteRequestStatus) ([]DeleteRequest, error) + Name func() string + RemoveDeleteRequests func(ctx context.Context, req []DeleteRequest) error + Stop func() + UpdateStatus func(ctx context.Context, req DeleteRequest, newStatus DeleteRequestStatus) error + func NewDeleteStore(workingDirectory string, indexStorageClient storage.Client) (DeleteRequestsStore, error) + func NewNoOpDeleteRequestsStore() DeleteRequestsStore + type DeleteRequestsStoreOption func(c *deleteRequestsClient) + func WithRequestClientCacheDuration(d time.Duration) DeleteRequestsStoreOption + type GRPCRequestHandler struct + func NewGRPCRequestHandler(deleteRequestsStore DeleteRequestsStore, limits Limits) *GRPCRequestHandler + func (g *GRPCRequestHandler) GetCacheGenNumbers(ctx context.Context, _ *grpc.GetCacheGenNumbersRequest) (*grpc.GetCacheGenNumbersResponse, error) + func (g *GRPCRequestHandler) GetDeleteRequests(ctx context.Context, _ *grpc.GetDeleteRequestsRequest) (*grpc.GetDeleteRequestsResponse, error) + type Limits interface + DeletionMode func(userID string) string + RetentionPeriod func(userID string) time.Duration + StreamRetention func(userID string) []validation.StreamRetention