Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetResourceMetrics (0.08 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 getResourceKey(name MetricName, labels map[string]string) string {
    	// labels are used to uniquely identify a metric
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K 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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top