- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetBandwidthReports (0.2 sec)
-
cmd/bucket-replication-handlers.go
return } w.Header().Set(xhttp.ContentType, string(mimeJSON)) enc := json.NewEncoder(w) stats := globalReplicationStats.getLatestReplicationStats(bucket) bwRpt := globalNotificationSys.GetBandwidthReports(ctx, bucket) bwMap := bwRpt.BucketStats for arn, st := range stats.ReplicationStats.Stats { for opts, bw := range bwMap { if opts.ReplicationARN != "" && opts.ReplicationARN == arn {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
cmd/notification.go
remote, all := newPeerRestClients(endpoints) return &NotificationSys{ peerClients: remote, allPeerClients: all, } } // GetBandwidthReports - gets the bandwidth report from all nodes including self. func (sys *NotificationSys) GetBandwidthReports(ctx context.Context, buckets ...string) bandwidth.BucketBandwidthReport { reports := make([]*bandwidth.BucketBandwidthReport, len(sys.peerClients))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0)