- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getNodeQueueStats (0.08 sec)
-
cmd/bucket-stats.go
QStats InQueueMetric `json:"queueStats"` MRFStats ReplicationMRFStats `json:"mrfStats"` } // getNodeQueueStats returns replication operational stats at the node level func (r *ReplicationStats) getNodeQueueStats(bucket string) (qs ReplQNodeStats) { qs.NodeName = globalLocalNodeName qs.Uptime = UTCNow().Unix() - globalBootTime.Unix() grs := globalReplicationStats.Load()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.5K bytes - Viewed (0) -
cmd/notification.go
} if st := globalReplicationStats.Load(); st != nil { bucketStats = append(bucketStats, BucketStats{ ReplicationStats: st.Get(bucketName), QueueStats: ReplicationQueueStats{Nodes: []ReplQNodeStats{st.getNodeQueueStats(bucketName)}}, ProxyStats: st.getProxyStats(bucketName), }) } return bucketStats } // GetClusterSiteMetrics - calls GetClusterSiteMetrics call on all peers for a cluster statistics view.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0) -
cmd/peer-rest-server.go
if st == nil { return &BucketStats{}, nil } bs := BucketStats{ ReplicationStats: st.Get(bucketName), QueueStats: ReplicationQueueStats{Nodes: []ReplQNodeStats{st.getNodeQueueStats(bucketName)}}, ProxyStats: st.getProxyStats(bucketName), } return &bs, nil } // GetSRMetricsHandler - fetches current in-memory replication stats at site level from this peer
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0)