@@ -20,21 +20,22 @@ import (
20
20
)
21
21
22
22
type ShuffleShardingGrouper struct {
23
- logger log.Logger
24
- bkt objstore.Bucket
25
- acceptMalformedIndex bool
26
- enableVerticalCompaction bool
27
- reg prometheus.Registerer
28
- blocksMarkedForDeletion prometheus.Counter
29
- blocksMarkedForNoCompact prometheus.Counter
30
- garbageCollectedBlocks prometheus.Counter
31
- hashFunc metadata.HashFunc
32
- compactions * prometheus.CounterVec
33
- compactionRunsStarted * prometheus.CounterVec
34
- compactionRunsCompleted * prometheus.CounterVec
35
- compactionFailures * prometheus.CounterVec
36
- verticalCompactions * prometheus.CounterVec
37
- compactorCfg Config
23
+ logger log.Logger
24
+ bkt objstore.Bucket
25
+ acceptMalformedIndex bool
26
+ enableVerticalCompaction bool
27
+ reg prometheus.Registerer
28
+ blocksMarkedForDeletion prometheus.Counter
29
+ blocksMarkedForNoCompact prometheus.Counter
30
+ garbageCollectedBlocks prometheus.Counter
31
+ remainingPlannedCompactions prometheus.Gauge
32
+ hashFunc metadata.HashFunc
33
+ compactions * prometheus.CounterVec
34
+ compactionRunsStarted * prometheus.CounterVec
35
+ compactionRunsCompleted * prometheus.CounterVec
36
+ compactionFailures * prometheus.CounterVec
37
+ verticalCompactions * prometheus.CounterVec
38
+ compactorCfg Config
38
39
}
39
40
40
41
func NewShuffleShardingGrouper (
@@ -55,15 +56,16 @@ func NewShuffleShardingGrouper(
55
56
}
56
57
57
58
return & ShuffleShardingGrouper {
58
- logger : logger ,
59
- bkt : bkt ,
60
- acceptMalformedIndex : acceptMalformedIndex ,
61
- enableVerticalCompaction : enableVerticalCompaction ,
62
- reg : reg ,
63
- blocksMarkedForDeletion : blocksMarkedForDeletion ,
64
- blocksMarkedForNoCompact : blocksMarkedForNoCompact ,
65
- garbageCollectedBlocks : garbageCollectedBlocks ,
66
- hashFunc : hashFunc ,
59
+ logger : logger ,
60
+ bkt : bkt ,
61
+ acceptMalformedIndex : acceptMalformedIndex ,
62
+ enableVerticalCompaction : enableVerticalCompaction ,
63
+ reg : reg ,
64
+ blocksMarkedForDeletion : blocksMarkedForDeletion ,
65
+ blocksMarkedForNoCompact : blocksMarkedForNoCompact ,
66
+ garbageCollectedBlocks : garbageCollectedBlocks ,
67
+ remainingPlannedCompactions : remainingPlannedCompactions ,
68
+ hashFunc : hashFunc ,
67
69
// Metrics are copied from Thanos DefaultGrouper constructor
68
70
compactions : promauto .With (reg ).NewCounterVec (prometheus.CounterOpts {
69
71
Name : "thanos_compact_group_compactions_total" ,
0 commit comments