Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + var ErrDeleteRequestNotFound = errors.New("could not find matching delete request") + func AllModes() []string + func FilteringEnabled(in string) (bool, error) + type DeleteRequest struct + CreatedAt model.Time + EndTime model.Time + Query string + RequestID string + StartTime model.Time + Status DeleteRequestStatus + UserID string + func (d *DeleteRequest) IsDeleted(entry retention.ChunkEntry) (bool, []model.Interval) + func (d *DeleteRequest) SetQuery(logQL string) error + 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 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, []model.Interval) + func (d *DeleteRequestsManager) IntervalMayHaveExpiredChunks(_ model.Interval, userID string) bool + func (d *DeleteRequestsManager) MarkPhaseFailed() + func (d *DeleteRequestsManager) MarkPhaseFinished() + func (d *DeleteRequestsManager) MarkPhaseStarted() + 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 Mode int16 + const Disabled + const FilterAndDelete + const FilterOnly + const WholeStreamDeletion + func ParseMode(in string) (Mode, error) + func (m Mode) String() string