Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for incrementBytes (0.07 sec)

  1. 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)
  2. 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)
Back to top