Skip to content

Commit 1fa4d4f

Browse files
committedDec 7, 2024
Add metric with number of checkpoints
1 parent f3f475f commit 1fa4d4f

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed
 

‎src/Index.zig

+4-2
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,8 @@ fn doCheckpoint(self: *Self) !bool {
222222
self.memory_segments.commitUpdate(&memory_segments_update);
223223
self.file_segments.commitUpdate(&file_segments_update);
224224

225+
metrics.checkpoint();
226+
225227
self.maybeScheduleFileSegmentMerge();
226228

227229
return true;
@@ -266,7 +268,7 @@ fn maybeMergeFileSegments(self: *Self) !bool {
266268
defer self.segments_lock.unlock();
267269

268270
self.file_segments.commitUpdate(&upd);
269-
// log.debug("committed file segments merge", .{});
271+
270272
metrics.fileSegmentMerge();
271273

272274
return true;
@@ -294,7 +296,7 @@ fn maybeMergeMemorySegments(self: *Self) !bool {
294296
defer self.segments_lock.unlock();
295297

296298
self.memory_segments.commitUpdate(&upd);
297-
// log.debug("committed memory segments merge", .{});
299+
298300
metrics.memorySegmentMerge();
299301

300302
self.maybeScheduleCheckpoint();

‎src/metrics.zig

+6
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ var metrics = m.initializeNoop(Metrics);
55
const Metrics = struct {
66
searches: m.Counter(u64),
77
updates: m.Counter(u64),
8+
checkpoints: m.Counter(u64),
89
memory_segment_merges: m.Counter(u64),
910
file_segment_merges: m.Counter(u64),
1011
};
@@ -17,6 +18,10 @@ pub fn update(count: usize) void {
1718
metrics.updates.incrBy(@intCast(count));
1819
}
1920

21+
pub fn checkpoint() void {
22+
metrics.checkpoints.incr();
23+
}
24+
2025
pub fn memorySegmentMerge() void {
2126
metrics.memory_segment_merges.incr();
2227
}
@@ -29,6 +34,7 @@ pub fn initializeMetrics(comptime opts: m.RegistryOpts) !void {
2934
metrics = .{
3035
.searches = m.Counter(u64).init("searches_total", .{}, opts),
3136
.updates = m.Counter(u64).init("updates_total", .{}, opts),
37+
.checkpoints = m.Counter(u64).init("checkpoints_total", .{}, opts),
3238
.memory_segment_merges = m.Counter(u64).init("memory_segment_merges_total", .{}, opts),
3339
.file_segment_merges = m.Counter(u64).init("file_segment_merges_total", .{}, opts),
3440
};

0 commit comments

Comments
 (0)