Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + var ErrDeleteRequestNotFound = errors.New("could not find matching delete request") + func TenantMiddleware(limits Limits, next http.Handler) http.Handler + type DeleteRequest struct + CreatedAt model.Time + DeletedLines int32 + EndTime model.Time + Metrics *deleteRequestsManagerMetrics + Query string + RequestID string + StartTime model.Time + Status DeleteRequestStatus + UserID string + func (d *DeleteRequest) FilterFunction(labels labels.Labels) (filter.Func, error) + func (d *DeleteRequest) IsDeleted(entry retention.ChunkEntry) (bool, []retention.IntervalFilter) + func (d *DeleteRequest) SetQuery(logQL string) error + type DeleteRequestClientMetrics struct + func NewDeleteRequestClientMetrics(r prometheus.Registerer) *DeleteRequestClientMetrics + type DeleteRequestHandler struct + func NewDeleteRequestHandler(deleteStore DeleteRequestsStore, deleteRequestCancelPeriod 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(addr string, c httpClient, deleteClientMetrics *DeleteRequestClientMetrics, ...) (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, []retention.IntervalFilter) + 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 + AddDeleteRequest func(ctx context.Context, userID string, startTime, endTime model.Time, ...) error + GetAllDeleteRequestsForUser func(ctx context.Context, userID string) ([]DeleteRequest, error) + GetCacheGenerationNumber func(ctx context.Context, userID string) (string, error) + GetDeleteRequest func(ctx context.Context, userID, requestID string) (*DeleteRequest, error) + GetDeleteRequestsByStatus func(ctx context.Context, status DeleteRequestStatus) ([]DeleteRequest, error) + Name func() string + RemoveDeleteRequest func(ctx context.Context, userID, requestID string, ...) error + Stop func() + UpdateStatus func(ctx context.Context, userID, requestID string, newStatus DeleteRequestStatus) error + func NewDeleteStore(workingDirectory string, indexStorageClient storage.Client) (DeleteRequestsStore, error) + func NewDeleteStoreFromIndexClient(ic index.Client) DeleteRequestsStore + func NewNoOpDeleteRequestsStore() DeleteRequestsStore + type DeleteRequestsStoreOption func(c *deleteRequestsClient) + func WithRequestClientCacheDuration(d time.Duration) DeleteRequestsStoreOption + type Limits interface + DeletionMode func(userID string) string