Fix metric names
This commit is contained in:
parent
68d8b5240c
commit
b493decd64
@ -175,15 +175,15 @@ public class LLLocalDictionary implements LLDictionary {
|
||||
this.startedGet = meterRegistry.counter("db.read.map.get.started.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.endedGet = meterRegistry.counter("db.read.map.get.ended.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.getTime = Timer
|
||||
.builder("db.read.get.timer")
|
||||
.builder("db.read.map.get.timer")
|
||||
.publishPercentiles(0.2, 0.5, 0.95)
|
||||
.publishPercentileHistogram()
|
||||
.tags("db.name", databaseName, "db.column", columnName)
|
||||
.register(meterRegistry);
|
||||
this.startedContains = meterRegistry.counter("db.read.map.get.started.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.endedContains = meterRegistry.counter("db.read.map.get.ended.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.startedContains = meterRegistry.counter("db.read.map.contains.started.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.endedContains = meterRegistry.counter("db.read.map.contains.ended.counter", "db.name", databaseName, "db.column", columnName);
|
||||
this.containsTime = Timer
|
||||
.builder("db.read.get.timer")
|
||||
.builder("db.read.map.contains.timer")
|
||||
.publishPercentiles(0.2, 0.5, 0.95)
|
||||
.publishPercentileHistogram()
|
||||
.tags("db.name", databaseName, "db.column", columnName)
|
||||
|
@ -4,6 +4,7 @@ import static io.net5.buffer.api.StandardAllocationTypes.OFF_HEAP;
|
||||
import static it.cavallium.dbengine.database.LLUtils.MARKER_ROCKSDB;
|
||||
|
||||
import io.micrometer.core.instrument.MeterRegistry;
|
||||
import io.micrometer.core.instrument.Timer;
|
||||
import io.net5.buffer.api.BufferAllocator;
|
||||
import io.net5.util.internal.PlatformDependent;
|
||||
import it.cavallium.dbengine.client.DatabaseOptions;
|
||||
@ -77,6 +78,8 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase {
|
||||
private final MeterRegistry meterRegistry;
|
||||
private final Scheduler dbScheduler;
|
||||
|
||||
private final Timer snapshotTime;
|
||||
|
||||
// Configurations
|
||||
|
||||
private final Path dbPath;
|
||||
@ -103,6 +106,13 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase {
|
||||
this.nettyDirect = databaseOptions.allowNettyDirect() && allocator.getAllocationType() == OFF_HEAP;
|
||||
this.meterRegistry = meterRegistry;
|
||||
|
||||
this.snapshotTime = Timer
|
||||
.builder("db.snapshot.timer")
|
||||
.publishPercentiles(0.2, 0.5, 0.95)
|
||||
.publishPercentileHistogram()
|
||||
.tags("db.name", name)
|
||||
.register(meterRegistry);
|
||||
|
||||
if (nettyDirect) {
|
||||
if (!PlatformDependent.hasUnsafe()) {
|
||||
throw new UnsupportedOperationException("Please enable unsafe support or disable netty direct buffers",
|
||||
@ -586,12 +596,12 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase {
|
||||
@Override
|
||||
public Mono<LLSnapshot> takeSnapshot() {
|
||||
return Mono
|
||||
.fromCallable(() -> {
|
||||
.fromCallable(() -> snapshotTime.recordCallable(() -> {
|
||||
var snapshot = db.getSnapshot();
|
||||
long currentSnapshotSequenceNumber = nextSnapshotNumbers.getAndIncrement();
|
||||
this.snapshotsHandles.put(currentSnapshotSequenceNumber, snapshot);
|
||||
return new LLSnapshot(currentSnapshotSequenceNumber);
|
||||
})
|
||||
}))
|
||||
.subscribeOn(dbScheduler);
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user