- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetBucketMetrics (0.17 sec)
-
cmd/notification.go
} go func(wg *sync.WaitGroup, ch chan MetricV2) { wg.Wait() xioutil.SafeClose(ch) }(&wg, ch) return ch } // GetBucketMetrics - gets the cluster level bucket metrics from all nodes excluding self. func (sys *NotificationSys) GetBucketMetrics(ctx context.Context) <-chan MetricV2 { if sys == nil { return nil } g := errgroup.WithNErrs(len(sys.peerClients))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/metrics-v2.go
} } // Call peer api to fetch metrics wg.Add(2) go publish(ReportMetrics(GlobalContext, c.metricsGroups)) go publish(globalNotificationSys.GetBucketMetrics(GlobalContext)) wg.Wait() } //msgp:ignore minioClusterCollector type minioClusterCollector struct { metricsGroups []*MetricsGroupV2 desc *prometheus.Desc }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0)