Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetResourceMetrics (0.22 sec)

  1. cmd/metrics-resource.go

    		cpuLoad5Perc:      "CPU load average 5min (percentage)",
    		cpuLoad15Perc:     "CPU load average 15min (percentage)",
    	}
    	resourceMetricsGroups = []*MetricsGroupV2{
    		getResourceMetrics(),
    	}
    
    	resourceCollector = newMinioResourceCollector(resourceMetricsGroups)
    }
    
    func updateResourceMetrics(subSys MetricSubsystem, name MetricName, val float64, labels map[string]string, isCumulative bool) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Apr 17 05:10:25 GMT 2024
    - 17.3K bytes
    - Viewed (0)
  2. cmd/notification.go

    			reply[index].Errors = []string{fmt.Sprintf("%s: %s (rpc)", sys.peerClients[index].String(), err.Error())}
    		}
    	}
    	return reply
    }
    
    // GetResourceMetrics - gets the resource metrics from all nodes excluding self.
    func (sys *NotificationSys) GetResourceMetrics(ctx context.Context) <-chan MetricV2 {
    	if sys == nil {
    		return nil
    	}
    	g := errgroup.WithNErrs(len(sys.peerClients))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	buckets := params.Values().Get("buckets")
    	selectBuckets := b.SelectBuckets(buckets)
    	return globalBucketMonitor.GetReport(selectBuckets), nil
    }
    
    func (s *peerRESTServer) GetResourceMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) {
    	res := make([]*MetricV2, 0, len(resourceMetricsGroups))
    	populateAndPublish(resourceMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    	values := grid.NewURLValuesWith(map[string][]string{
    		peerRESTBuckets: buckets,
    	})
    	return getBandwidthRPC.Call(ctx, client.gridConn(), values)
    }
    
    func (client *peerRESTClient) GetResourceMetrics(ctx context.Context) (<-chan MetricV2, error) {
    	resp, err := getResourceMetricsRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil {
    		return nil, err
    	}
    	ch := make(chan MetricV2)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
Back to top