SegmentManagerGroupRef&& sm_group,
BackrefManager &backref_manager,
SegmentSeqAllocator &segment_seq_allocator,
- bool detailed)
+ bool detailed,
+ bool is_cold)
: detailed(detailed),
+ is_cold(is_cold),
config(config),
sm_group(std::move(sm_group)),
backref_manager(backref_manager),
i = get_bucket_index(UTIL_STATE_EMPTY);
stats.segment_util.buckets[i].count = segments.get_num_segments();
- metrics.add_group("segment_cleaner", {
+ std::string prefix;
+ if (is_cold) {
+ prefix.append("cold_");
+ }
+ prefix.append("segment_cleaner");
+
+ metrics.add_group(prefix, {
sm::make_counter("segments_number",
[this] { return segments.get_num_segments(); },
sm::description("the number of segments")),
SegmentManagerGroupRef&& sm_group,
BackrefManager &backref_manager,
SegmentSeqAllocator &segment_seq_allocator,
- bool detailed);
+ bool detailed,
+ bool is_cold);
void set_journal_trimmer(JournalTrimmer &_trimmer) {
trimmer = &_trimmer;
SegmentManagerGroupRef&& sm_group,
BackrefManager &backref_manager,
SegmentSeqAllocator &ool_seq_allocator,
- bool detailed) {
+ bool detailed,
+ bool is_cold = false) {
return std::make_unique<SegmentCleaner>(
- config, std::move(sm_group), backref_manager, ool_seq_allocator, detailed);
+ config, std::move(sm_group), backref_manager,
+ ool_seq_allocator, detailed, is_cold);
}
/*
}
const bool detailed;
+ const bool is_cold;
const config_t config;
SegmentManagerGroupRef sm_group;