assertTrue(cbWithMetrics.getP95ResponseTime() > 0, "P95 response time should be tracked");

            SmbCircuitBreaker.CircuitBreakerMetrics metrics = cbWithMetrics.getMetrics();
            assertNotNull(metrics, "Metrics should be available");
            assertEquals(3, metrics.totalRequests(), "Should have 3 requests");

        log.debug("[{}] Started dynamic threshold adjustment task", name);
    }

    private void performDynamicThresholdAdjustment() {
        try {
            RollingWindow.WindowMetrics metrics = rollingWindow.getMetrics();
            double failureRate = metrics.getFailureRate();
            long avgResponseTime = metrics.getAverageResponseTime();

            // Adjust threshold based on failure rate and response time trends

}

func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
	if !globalIsDistErasure {
		return
	}
	all := globalNotificationSys.GetMetrics(ctx, types, opts)
	for _, remote := range all {
		m.Merge(&remote)
	}
	return m

	}

	for index, err := range g.Wait() {
		if err != nil {
			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
		}
	}
	return reply
}

// GetMetrics - Get metrics from all peers.
func (sys *NotificationSys) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) []madmin.RealtimeMetrics {
	reply := make([]madmin.RealtimeMetrics, len(sys.peerClients))

	health       *diskHealthTracker
	healthCheck  bool

	metricsCache *cachevalue.Cache[DiskMetrics]
	diskCtx      context.Context
	diskCancel   context.CancelFunc
}

func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
	p.metricsCache.InitOnce(5*time.Second,
		cachevalue.Opts{},
		func(ctx context.Context) (DiskMetrics, error) {
			diskMetric := DiskMetrics{

	resp, err := getMemInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
	return resp.ValueOrZero(), err
}

// GetMetrics - fetch metrics from a remote node.
func (client *peerRESTClient) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) (info madmin.RealtimeMetrics, err error) {
	values := make(url.Values)

- Support `FakeClientset`...