-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
compact: Added support for no-compact markers in planner.
The planner algo was adapted to avoid unnecessary changes to blocks caused by excluded blocks, so we can quickly switch to different planning logic in next iteration. Fixes: #1424 Signed-off-by: Bartlomiej Plotka <bwplotka@gmail.com>
- Loading branch information
Showing
9 changed files
with
583 additions
and
192 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,115 @@ | ||
| // Copyright (c) The Thanos Authors. | ||
| // Licensed under the Apache License 2.0. | ||
|
|
||
| package metadata | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "io/ioutil" | ||
| "path" | ||
|
|
||
| "github.com/go-kit/kit/log" | ||
| "github.com/oklog/ulid" | ||
| "github.com/pkg/errors" | ||
| "github.com/thanos-io/thanos/pkg/objstore" | ||
| "github.com/thanos-io/thanos/pkg/runutil" | ||
| ) | ||
|
|
||
| const ( | ||
| // DeletionMarkFilename is the known json filename for optional file storing details about when block is marked for deletion. | ||
| // If such file is present in block dir, it means the block is meant to be deleted after certain delay. | ||
| DeletionMarkFilename = "deletion-mark.json" | ||
| // NoCompactMarkFilename is the known json filename for optional file storing details about why block has to be excluded from compaction. | ||
| // If such file is present in block dir, it means the block has to excluded from compaction (both vertical and horizontal) or rewrite (e.g deletions). | ||
| NoCompactMarkFilename = "no-compact-mark.json" | ||
|
|
||
| // DeletionMarkVersion1 is the version of deletion-mark file supported by Thanos. | ||
| DeletionMarkVersion1 = 1 | ||
| // NoCompactMarkVersion1 is the version of no-compact-mark file supported by Thanos. | ||
| NoCompactMarkVersion1 = 1 | ||
| ) | ||
|
|
||
| var ( | ||
| // ErrorMarkerNotFound is the error when marker file is not found. | ||
| ErrorMarkerNotFound = errors.New("marker not found") | ||
| // ErrorUnmarshalMarker is the error when unmarshalling marker JSON file. | ||
| // This error can occur because marker has been partially uploaded to block storage | ||
| // or the marker file is not a valid json file. | ||
| ErrorUnmarshalMarker = errors.New("unmarshal marker JSON") | ||
| ) | ||
|
|
||
| type Marker interface { | ||
| markerFilename() string | ||
| } | ||
|
|
||
| // DeletionMark stores block id and when block was marked for deletion. | ||
| type DeletionMark struct { | ||
| // ID of the tsdb block. | ||
| ID ulid.ULID `json:"id"` | ||
| // Version of the file. | ||
| Version int `json:"version"` | ||
|
|
||
| // DeletionTime is a unix timestamp of when the block was marked to be deleted. | ||
| DeletionTime int64 `json:"deletion_time"` | ||
| } | ||
|
|
||
| func (m *DeletionMark) markerFilename() string { return DeletionMarkFilename } | ||
|
|
||
| // NoCompactReason is a reason for a block to be excluded from compaction. | ||
| type NoCompactReason string | ||
|
|
||
| const ( | ||
| // ManualNoCompactReason is a custom reason of excluding from compaction that should be added when no-compact mark is added for unknown/user specified reason. | ||
| ManualNoCompactReason NoCompactReason = "manual" | ||
| // IndexSizeExceedingNoCompactReason is a reason of index being too big (for example exceeding 64GB limit: https://github.com/thanos-io/thanos/issues/1424) | ||
| // This reason can be ignored when vertical block sharding will be implemented. | ||
| IndexSizeExceedingNoCompactReason = "index-size-exceeding" | ||
| ) | ||
|
|
||
| // NoCompactMark marker stores reason of block being excluded from compaction if needed. | ||
| type NoCompactMark struct { | ||
| // ID of the tsdb block. | ||
| ID ulid.ULID `json:"id"` | ||
| // Version of the file. | ||
| Version int `json:"version"` | ||
|
|
||
| Reason NoCompactReason `json:"reason"` | ||
| // Details is a human readable string giving details of reason. | ||
| Details string `json:"details"` | ||
| } | ||
|
|
||
| func (n *NoCompactMark) markerFilename() string { return NoCompactMarkFilename } | ||
|
|
||
| // ReadMarker reads the given mark file from <dir>/<marker filename>.json in bucket. | ||
| func ReadMarker(ctx context.Context, logger log.Logger, bkt objstore.InstrumentedBucketReader, dir string, marker Marker) error { | ||
| markerFile := path.Join(dir, marker.markerFilename()) | ||
| r, err := bkt.ReaderWithExpectedErrs(bkt.IsObjNotFoundErr).Get(ctx, markerFile) | ||
| if err != nil { | ||
| if bkt.IsObjNotFoundErr(err) { | ||
| return ErrorMarkerNotFound | ||
| } | ||
| return errors.Wrapf(err, "get file: %s", markerFile) | ||
| } | ||
| defer runutil.CloseWithLogOnErr(logger, r, "close bkt marker reader") | ||
|
|
||
| metaContent, err := ioutil.ReadAll(r) | ||
| if err != nil { | ||
| return errors.Wrapf(err, "read file: %s", markerFile) | ||
| } | ||
|
|
||
| if err := json.Unmarshal(metaContent, marker); err != nil { | ||
| return errors.Wrapf(ErrorUnmarshalMarker, "file: %s; err: %v", markerFile, err.Error()) | ||
| } | ||
| switch marker.markerFilename() { | ||
| case NoCompactMarkFilename: | ||
| if version := marker.(*NoCompactMark).Version; version != NoCompactMarkVersion1 { | ||
| return errors.Errorf("unexpected no-compact-mark file version %d, expected %d", version, NoCompactMarkVersion1) | ||
| } | ||
| case DeletionMarkFilename: | ||
| if version := marker.(*DeletionMark).Version; version != DeletionMarkVersion1 { | ||
| return errors.Errorf("unexpected deletion-mark file version %d, expected %d", version, DeletionMarkVersion1) | ||
| } | ||
| } | ||
| return nil | ||
| } |
Oops, something went wrong.