public PoolHealthMetrics(int activeConnections, int nonPooledConnections, int trackedConnections, int maxPoolSize,
                long totalHealthChecks, long failedHealthChecks, long connectionsRemoved, int uniqueEndpoints,
                boolean healthCheckingEnabled, boolean proactiveHealthCheckEnabled) {
            this.activeConnections = activeConnections;
            this.nonPooledConnections = nonPooledConnections;

	activeConnections uint64
	sync.RWMutex
}

func (n *netPerfRX) Connect() {
	n.Lock()
	defer n.Unlock()
	n.activeConnections++
	atomic.StoreUint64(&n.RX, 0)
	n.lastToConnect = time.Now()
}

func (n *netPerfRX) Disconnect() {
	n.Lock()
	defer n.Unlock()
	n.activeConnections--
	if n.firstToDisconnect.IsZero() {

        }

        public int getActiveConnections() {
            return activeConnections.get();
        }

        public void incrementConnections() {
            activeConnections.incrementAndGet();
        }

        public void decrementConnections() {
            activeConnections.decrementAndGet();
        }

        public boolean isHealthy() {
            return isHealthy;

    @Override
    public String toString() {
        return String.format(
                "RdmaStatistics[reads=%d, writes=%d, sends=%d, receives=%d, "
                        + "bytes=%d, errors=%d, errorRate=%.3f, activeConnections=%d, activeMemRegions=%d]",
                rdmaReads.get(), rdmaWrites.get(), rdmaSends.get(), rdmaReceives.get(), bytesTransferred.get(), operationErrors.get(),