Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getResourceMetrics (0.15 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-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