Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getMetrics (0.41 sec)

  1. cmd/xl-storage-disk-id-check.go

    	health       *diskHealthTracker
    	healthCheck  bool
    
    	metricsCache *cachevalue.Cache[DiskMetrics]
    	diskCtx      context.Context
    	diskCancel   context.CancelFunc
    }
    
    func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
    	p.metricsCache.InitOnce(5*time.Second,
    		cachevalue.Opts{},
    		func(ctx context.Context) (DiskMetrics, error) {
    			diskMetric := DiskMetrics{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    	resp, err := getMemInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // GetMetrics - fetch metrics from a remote node.
    func (client *peerRESTClient) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) (info madmin.RealtimeMetrics, err error) {
    	values := make(url.Values)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/notification.go

    	}
    
    	for index, err := range g.Wait() {
    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetMetrics - Get metrics from all peers.
    func (sys *NotificationSys) GetMetrics(ctx context.Context, t madmin.MetricType, opts collectMetricsOpts) []madmin.RealtimeMetrics {
    	reply := make([]madmin.RealtimeMetrics, 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)
Back to top