- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for incrementBytes (0.07 sec)
-
internal/bucket/bandwidth/monitor_test.go
endTime time.Time update2 uint64 endTime2 time.Time } start := time.Now() m0 := newBucketMeasurement(start) m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.3K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} func (m *Monitor) updateMeasurement(opts BucketOptions, bytes uint64) { m.mlock.Lock() defer m.mlock.Unlock() tm, ok := m.bucketsMeasurement[opts] if !ok { tm = &bucketMeasurement{} } tm.incrementBytes(bytes) m.bucketsMeasurement[opts] = tm } // SelectionFunction for buckets type SelectionFunction func(bucket string) bool // SelectBuckets will select all the buckets passed in.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0)