func loadClusterReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
	st := globalReplicationStats.Load()
	if st == nil {
		return nil
	}

	qs := st.getNodeQueueStatsSummary()

	qt := qs.QStats
	m.Set(replicationAverageQueuedBytes, float64(qt.Avg.Bytes))
	m.Set(replicationAverageQueuedCount, float64(qt.Avg.Count))
	m.Set(replicationMaxQueuedBytes, float64(qt.Max.Bytes))

			Curr: (lcurr + scurr) / float64(count),
			Peak: totpeak,
		}
	}
	return qs
}

// populate queue totals for node and active workers in use for metrics
func (r *ReplicationStats) getNodeQueueStatsSummary() (qs ReplQNodeStats) {
	qs.NodeName = globalLocalNodeName
	qs.Uptime = UTCNow().Unix() - globalBootTime.Unix()
	qs.ActiveWorkers = globalReplicationStats.Load().ActiveWorkers()

		var ml []MetricV2
		// common operational metrics for bucket replication and site replication - published
		// at cluster level
		if rStats := globalReplicationStats.Load(); rStats != nil {
			qs := rStats.getNodeQueueStatsSummary()
			activeWorkersCount := MetricV2{
				Description: getClusterReplActiveWorkersCountMD(),
			}
			avgActiveWorkersCount := MetricV2{
				Description: getClusterReplAvgActiveWorkersCountMD(),
			}