Added metadata.NoDownsampleMarkVersion1 field

Signed-off-by: Rohit Singh <rohitkochhar@bitgo.com>
thanos-io · Dec 7, 2022 · 5fe8343 · 5fe8343
1 parent 554c55d
commit 5fe8343
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/pkg/block/block.go b/pkg/block/block.go
@@ -416,7 +416,7 @@ func MarkForNoDownsample(ctx context.Context, logger log.Logger, bkt objstore.Bu
 	}
 	noDownsampleMark, err := json.Marshal(metadata.NoDownsampleMark{
 		ID:      id,
-		Version: metadata.NoCompactMarkVersion1,
+		Version: metadata.NoDownsampleMarkVersion1,
 
 		NoDownsampleTime: time.Now().Unix(),
 		Reason:           reason,

diff --git a/pkg/block/metadata/markers.go b/pkg/block/metadata/markers.go
@@ -31,6 +31,8 @@ const (
 	DeletionMarkVersion1 = 1
 	// NoCompactMarkVersion1 is the version of no-compact-mark file supported by Thanos.
 	NoCompactMarkVersion1 = 1
+	// NoDownsampleVersion1 is the version of no-downsample-mark file supported by Thanos.
+	NoDownsampleMarkVersion1 = 1
 )
 
 var (

diff --git a/pkg/compact/downsample/downsample.go b/pkg/compact/downsample/downsample.go
@@ -759,7 +759,7 @@ func NewGatherNoDownsampleMarkFilter(logger log.Logger, bkt objstore.Instrumente
 	}
 }
 
-// NoDownsampleMarkedBlocks returns block ids that were marked for no downsample
+// NoDownsampleMarkedBlocks returns block ids that were marked for no downsample.
 func (f *GatherNoDownsampleMarkFilter) NoCompactMarkedBlocks() map[ulid.ULID]*metadata.NoDownsampleMark {
 	f.mtx.Lock()
 	copiedNoDownsampleMarked := make(map[ulid.ULID]*metadata.NoDownsampleMark, len(f.noDownsampleMarkedMap))