register.java

private void registerCounter(MetricRegistry metricRegistry,
                            ConnectionPoolMetrics cpm,
                            String poolPrefix,
                            String name,
                            Function<ConnectionPoolMetrics, Long> fn) {
   String counterName = poolPrefix + name;
   if (metricRegistry.getCounters().get(new MetricID(counterName)) == null) {
       Metadata metadata = Metadata.builder()
               .withName(counterName)
               .withType(MetricType.COUNTER)
               .notReusable()
               .build();
       Neo4JCounterWrapper wrapper = new Neo4JCounterWrapper(() -> fn.apply(cpm));
       metricRegistry.register(metadata, wrapper);
   }
}
private void registerGauge(MetricRegistry metricRegistry,
                          ConnectionPoolMetrics cpm,
                          String poolPrefix,
                          String name,
                          Function<ConnectionPoolMetrics, Integer> fn) {
   String gaugeName = poolPrefix + name;
   if (metricRegistry.getGauges().get(new MetricID(gaugeName)) == null) {
       Metadata metadata = Metadata.builder()
               .withName(poolPrefix + name)
               .withType(MetricType.GAUGE)
               .notReusable()
               .build();
       Neo4JGaugeWrapper<Integer> wrapper =
               new Neo4JGaugeWrapper<>(() -> fn.apply(cpm));
       metricRegistry.register(metadata, wrapper);
   }
}