Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/bucket/bandwidth/monitor.go

    	}
    	tm.incrementBytes(bytes)
    	m.bucketsMeasurement[opts] = tm
    }
    
    // SelectionFunction for buckets
    type SelectionFunction func(bucket string) bool
    
    // SelectBuckets will select all the buckets passed in.
    func SelectBuckets(buckets ...string) SelectionFunction {
    	if len(buckets) == 0 {
    		return func(bucket string) bool {
    			return true
    		}
    	}
    	return func(bucket string) bool {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor_test.go

    				bucketsThrottle:    th,
    				NodeCount:          1,
    			}
    			m.bucketsMeasurement[BucketOptions{Name: "bucket", ReplicationARN: "arn"}].updateExponentialMovingAverage(tt.fields.endTime)
    			got := m.GetReport(SelectBuckets())
    			if !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("GetReport() = %v, want %v", got, tt.want)
    			}
    			m.bucketsMeasurement[BucketOptions{Name: "bucket", ReplicationARN: "arn"}].incrementBytes(tt.fields.update2)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
Back to top