Polish "Add descriptions for data source pool metrics"

See gh-20354
This commit is contained in:
Stephane Nicoll 2020-03-01 10:59:38 -05:00
parent 21a0b0544a
commit 925756dae1
1 changed files with 16 additions and 14 deletions

View File

@ -1,5 +1,5 @@
/*
* Copyright 2012-2019 the original author or authors.
* Copyright 2012-2020 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -66,24 +66,26 @@ public class DataSourcePoolMetrics implements MeterBinder {
@Override
public void bindTo(MeterRegistry registry) {
if (this.metadataProvider.getDataSourcePoolMetadata(this.dataSource) != null) {
bindPoolMetadata(registry, "active", DataSourcePoolMetadata::getActive,
"Current number of active connections that have been allocated from the data source.");
bindPoolMetadata(registry, "idle", DataSourcePoolMetadata::getIdle,
"Number of established but idle connections.");
bindPoolMetadata(registry, "max", DataSourcePoolMetadata::getMax,
"Maximum number of active connections that can be allocated at the same time.");
bindPoolMetadata(registry, "min", DataSourcePoolMetadata::getMin,
"Minimum number of idle connections in the pool.");
bindPoolMetadata(registry, "active",
"Current number of active connections that have been allocated from the data source.",
DataSourcePoolMetadata::getActive);
bindPoolMetadata(registry, "idle", "Number of established but idle connections.",
DataSourcePoolMetadata::getIdle);
bindPoolMetadata(registry, "max",
"Maximum number of active connections that can be allocated at the same time.",
DataSourcePoolMetadata::getMax);
bindPoolMetadata(registry, "min", "Minimum number of idle connections in the pool.",
DataSourcePoolMetadata::getMin);
}
}
private <N extends Number> void bindPoolMetadata(MeterRegistry registry, String metricName,
Function<DataSourcePoolMetadata, N> function, String description) {
bindDataSource(registry, metricName, this.metadataProvider.getValueFunction(function), description);
private <N extends Number> void bindPoolMetadata(MeterRegistry registry, String metricName, String description,
Function<DataSourcePoolMetadata, N> function) {
bindDataSource(registry, metricName, description, this.metadataProvider.getValueFunction(function));
}
private <N extends Number> void bindDataSource(MeterRegistry registry, String metricName,
Function<DataSource, N> function, String description) {
private <N extends Number> void bindDataSource(MeterRegistry registry, String metricName, String description,
Function<DataSource, N> function) {
if (function.apply(this.dataSource) != null) {
Gauge.builder("jdbc.connections." + metricName, this.dataSource, (m) -> function.apply(m).doubleValue())
.tags(this.tags).description(description).register(registry);