- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for queueStats (0.37 sec)
-
cmd/bucket-stats_gen.go
if err != nil { err = msgp.WrapError(err, "QueueStats", "Nodes") return } if cap(z.QueueStats.Nodes) >= int(zb0003) { z.QueueStats.Nodes = (z.QueueStats.Nodes)[:zb0003] } else { z.QueueStats.Nodes = make([]ReplQNodeStats, zb0003) } for za0001 := range z.QueueStats.Nodes { err = z.QueueStats.Nodes[za0001].DecodeMsg(dc) if err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 57.3K 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 statisticsRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 46K bytes - Viewed (0) -
cmd/peer-rest-server.go
} st := globalReplicationStats.Load() 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 }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 53.6K bytes - Viewed (0)