- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for updateXferRate (0.58 sec)
-
cmd/site-replication-metrics.go
switch { case st.Completed: srs.ReplicatedSize += st.TransferSize srs.ReplicatedCount++ if st.TransferDuration > 0 { srs.Latency.update(st.TransferSize, st.TransferDuration) srs.updateXferRate(st.TransferSize, st.TransferDuration) } case st.Failed: srs.Failed.addsize(st.TransferSize, st.Err) case st.Pending: } sr.M[dID] = srs } func (sr *SRStats) get() map[string]SRMetric {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
cmd/bucket-stats.go
} func (bs *BucketReplicationStat) hasReplicationUsage() bool { return bs.FailStats.SinceUptime.Count > 0 || bs.ReplicatedSize > 0 || bs.ReplicaSize > 0 } func (bs *BucketReplicationStat) updateXferRate(sz int64, duration time.Duration) { if sz > minLargeObjSize { bs.XferRateLrg.addSize(sz, duration) } else { bs.XferRateSml.addSize(sz, duration) } } // RMetricName - name of replication metric
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.5K bytes - Viewed (0)