- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for updateXferRate (0.17 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 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
} switch { case rs.Completed: b.ReplicatedSize += rs.TransferSize b.ReplicatedCount++ if rs.TransferDuration > 0 { b.Latency.update(rs.TransferSize, rs.TransferDuration) b.updateXferRate(rs.TransferSize, rs.TransferDuration) } case rs.Failed: b.FailStats.addsize(rs.TransferSize, rs.Err) case rs.Pending: } } type replStat struct { Arn string Completed bool
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K 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
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0)