- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for QueueStats (0.07 sec)
-
cmd/bucket-replication-stats.go
var qs ReplicationQueueStats for _, bs := range bucketStats { qs.Nodes = append(qs.Nodes, bs.QueueStats.Nodes...) } qs.Uptime = UTCNow().Unix() - globalBootTime.Unix() var ps ProxyMetric for _, bs := range bucketStats { ps.add(bs.ProxyStats) } bs = BucketStats{ ReplicationStats: s, QueueStats: qs, ProxyStats: ps, } r.mostRecentStatsMu.Lock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 13.6K bytes - Viewed (0) -
cmd/bucket-stats.go
type BucketStats struct { Uptime int64 `json:"uptime"` ReplicationStats BucketReplicationStats `json:"currStats"` // current replication stats since cluster startup QueueStats ReplicationQueueStats `json:"queueStats"` // replication queue stats ProxyStats ProxyMetric `json:"proxyStats"` } // BucketReplicationStats represents inline replication statistics
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 }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0)