- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetReport (0.04 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.3K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/ConfiguredGoalSupport.java
response.isValid() ? "VALID" : "INVALID") .build()); for (Map.Entry<SecDispatcher.ValidationResponse.Level, List<String>> entry : response.getReport().entrySet()) { Consumer<String> consumer = s -> context.logger.info(messageBuilderFactory.builder().info(s).build()); if (entry.getKey() == SecDispatcher.ValidationResponse.Level.ERROR) {
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 4.2K bytes - Viewed (0)