- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getNodeQueueStats (0.16 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 11:39:51 UTC 2024 - 13.4K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0)