Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetReport (0.08 sec)

  1. internal/bucket/bandwidth/monitor.go

    	BucketStats map[BucketOptions]Details `json:"bucketStats,omitempty"`
    }
    
    // GetReport gets the report for all bucket bandwidth details.
    func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	m.mlock.RLock()
    	defer m.mlock.RUnlock()
    	return m.getReport(selectBucket)
    }
    
    func (m *Monitor) getReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	report := &BucketBandwidthReport{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor_test.go

    				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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 06 03:21:59 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/ConfiguredGoalSupport.java

                                    response.isValid() ? "VALID" : "INVALID"));
            for (Map.Entry<SecDispatcher.ValidationResponse.Level, List<String>> entry :
                    response.getReport().entrySet()) {
                Consumer<String> consumer = s -> context.terminal
                        .writer()
                        .println(messageBuilderFactory.builder().info(s).build());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top