- Sort Score
- Result 10 results
- Languages All
Results 31 - 32 of 32 for reporters (0.18 sec)
-
cmd/bucket-replication-metrics.go
func newRateMeasurement(initTime time.Time) *rateMeasurement { return &rateMeasurement{ startTime: initTime, } } // incrementBytes add bytes reported for a bucket/target. func (m *rateMeasurement) incrementBytes(bytes uint64) { atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/metacache-stream.go
if w.reuseBlocks || o.reusable { metaDataPoolPut(o.metadata) } } return nil } // stream entries to the output. // The returned channel should be closed when done. // Any error is reported when closing the metacacheWriter. func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) { if w.creator != nil { err := w.creator() w.creator = nil if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0)