Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for getMetrics (0.07 seconds)

  1. cmd/metrics-realtime.go

    }
    
    func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
    	if !globalIsDistErasure {
    		return m
    	}
    	all := globalNotificationSys.GetMetrics(ctx, types, opts)
    	for _, remote := range all {
    		m.Merge(&remote)
    	}
    	return m
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.3K bytes
    - Click Count (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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (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))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  4. 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{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  5. CHANGELOG/CHANGELOG-1.22.md

    - Support `FakeClientset`...
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Tue Dec 13 12:43:45 GMT 2022
    - 454.1K bytes
    - Click Count (0)
Back to Top