public record ConnectionPoolMetrics()

in zuul-core/src/main/java/com/netflix/zuul/netty/connectionpool/ConnectionPoolMetrics.java [30:105]
69 lines of code
1 McCabe index (conditional complexity)

public record ConnectionPoolMetrics(
        Counter createNewConnCounter,
        Counter createConnSucceededCounter,
        Counter createConnFailedCounter,
        Counter closeConnCounter,
        Counter closeAbovePoolHighWaterMarkCounter,
        Counter closeExpiredConnLifetimeCounter,
        Counter requestConnCounter,
        Counter reuseConnCounter,
        Counter releaseConnCounter,
        Counter alreadyClosedCounter,
        Counter connTakenFromPoolIsNotOpen,
        Counter maxConnsPerHostExceededCounter,
        Counter closeWrtBusyConnCounter,
        Counter circuitBreakerClose,
        PercentileTimer connEstablishTimer,
        AtomicInteger connsInPool,
        AtomicInteger connsInUse) {

    public static ConnectionPoolMetrics create(OriginName originName, Registry registry) {
        Counter createNewConnCounter = newCounter("connectionpool_create", originName, registry);
        Counter createConnSucceededCounter = newCounter("connectionpool_create_success", originName, registry);
        Counter createConnFailedCounter = newCounter("connectionpool_create_fail", originName, registry);

        Counter closeConnCounter = newCounter("connectionpool_close", originName, registry);
        Counter closeAbovePoolHighWaterMarkCounter =
                newCounter("connectionpool_closeAbovePoolHighWaterMark", originName, registry);
        Counter closeExpiredConnLifetimeCounter =
                newCounter("connectionpool_closeExpiredConnLifetime", originName, registry);
        Counter requestConnCounter = newCounter("connectionpool_request", originName, registry);
        Counter reuseConnCounter = newCounter("connectionpool_reuse", originName, registry);
        Counter releaseConnCounter = newCounter("connectionpool_release", originName, registry);
        Counter alreadyClosedCounter = newCounter("connectionpool_alreadyClosed", originName, registry);
        Counter connTakenFromPoolIsNotOpen = newCounter("connectionpool_fromPoolIsClosed", originName, registry);
        Counter maxConnsPerHostExceededCounter =
                newCounter("connectionpool_maxConnsPerHostExceeded", originName, registry);
        Counter closeWrtBusyConnCounter = newCounter("connectionpool_closeWrtBusyConnCounter", originName, registry);
        Counter circuitBreakerClose = newCounter("connectionpool_closeCircuitBreaker", originName, registry);

        PercentileTimer connEstablishTimer = PercentileTimer.get(
                registry, registry.createId("connectionpool_createTiming", "id", originName.getMetricId()));

        AtomicInteger connsInPool = newGauge("connectionpool_inPool", originName, registry);
        AtomicInteger connsInUse = newGauge("connectionpool_inUse", originName, registry);

        return new ConnectionPoolMetrics(
                createNewConnCounter,
                createConnSucceededCounter,
                createConnFailedCounter,
                closeConnCounter,
                closeAbovePoolHighWaterMarkCounter,
                closeExpiredConnLifetimeCounter,
                requestConnCounter,
                reuseConnCounter,
                releaseConnCounter,
                alreadyClosedCounter,
                connTakenFromPoolIsNotOpen,
                maxConnsPerHostExceededCounter,
                closeWrtBusyConnCounter,
                circuitBreakerClose,
                connEstablishTimer,
                connsInPool,
                connsInUse);
    }

    private static Counter newCounter(String metricName, OriginName originName, Registry registry) {
        return registry.counter(metricName, "id", originName.getMetricId());
    }

    private static AtomicInteger newGauge(String metricName, OriginName originName, Registry registry) {
        return PolledMeter.using(registry)
                .withName(metricName)
                .withTag("id", originName.getMetricId())
                .monitorValue(new AtomicInteger());
    }
}