- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for aggregate (0.17 sec)
-
internal/bucket/bandwidth/measurement.go
atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far. func (m *bucketMeasurement) updateExponentialMovingAverage(endTime time.Time) { // Calculate aggregate avg bandwidth and exp window avg m.lock.Lock() defer func() { m.startTime = endTime m.lock.Unlock() }() if m.startTime.IsZero() { return } if endTime.Before(m.startTime) { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0)