Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetRPCStats (0.24 sec)

  1. internal/rest/rpc-stats.go

    }{}
    
    // RPCStats holds information about the DHCP/TCP metrics and errors
    type RPCStats struct {
    	Errs uint64
    
    	DialAvgDuration uint64
    	DialErrs        uint64
    }
    
    // GetRPCStats returns RPC stats, include calls errors and dhcp/tcp metrics
    func GetRPCStats() RPCStats {
    	s := RPCStats{
    		Errs:     atomic.LoadUint64(&globalStats.errs),
    		DialErrs: atomic.LoadUint64(&globalStats.tcpDialErrs),
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Sep 29 16:27:58 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-network.go

    //
    // This is a `MetricsLoaderFn`.
    func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	connStats := globalConnStats.toServerConnStats()
    	rpcStats := rest.GetRPCStats()
    	if globalIsDistErasure {
    		m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
    		m.Set(internodeDialErrorsTotal, float64(rpcStats.DialErrs))
    		m.Set(internodeDialAvgTimeNanos, float64(rpcStats.DialAvgDuration))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		metrics = make([]MetricV2, 0, 10)
    		connStats := globalConnStats.toServerConnStats()
    		rpcStats := rest.GetRPCStats()
    		if globalIsDistErasure {
    			metrics = append(metrics, MetricV2{
    				Description: getInternodeFailedRequests(),
    				Value:       float64(rpcStats.Errs),
    			})
    			metrics = append(metrics, MetricV2{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 21:22:15 GMT 2024
    - 132.1K bytes
    - Viewed (0)
Back to top