Versions in this module Expand all Collapse all v3 v3.0.1 Mar 21, 2022 v3.0.0 Mar 21, 2022 Changes in this version + var ErrDeleteRequestNotFound = errors.New("could not find matching delete request") + type DeleteRequest struct + CreatedAt model.Time + EndTime model.Time + Matchers [][]*labels.Matcher + RequestID string + Selectors []string + StartTime model.Time + Status DeleteRequestStatus + UserID string + func (d *DeleteRequest) IsDeleted(entry retention.ChunkEntry) (bool, []model.Interval) + 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) + 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) + GetDeleteRequest func(ctx context.Context, userID, requestID string) (*DeleteRequest, error) + GetDeleteRequestsByStatus func(ctx context.Context, status DeleteRequestStatus) ([]DeleteRequest, error) + 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 chunk.IndexClient) DeleteRequestsStore + func NewNoOpDeleteRequestsStore() DeleteRequestsStore Other modules containing this package github.com/pao214/loki/v2