Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for GetPeerMetrics (0.05 sec)

  1. cmd/peer-rest-server.go

    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    // GetPeerMetrics gets the metrics to be federated across peers.
    func (s *peerRESTServer) GetPeerMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) {
    	res := make([]*MetricV2, 0, len(peerMetricsGroups))
    	populateAndPublish(peerMetricsGroups, func(m MetricV2) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  2. cmd/notification.go

    	for index := range sys.peerClients {
    		g.Go(func() error {
    			if sys.peerClients[index] == nil {
    				return errPeerNotReachable
    			}
    			var err error
    			peerChannels[index], err = sys.peerClients[index].GetPeerMetrics(ctx)
    			return err
    		}, index)
    	}
    	return sys.collectPeerMetrics(ctx, peerChannels, g)
    }
    
    // ServiceFreeze freezes all S3 API calls when 'freeze' is true,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
Back to top