Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ConnStats (0.11 sec)

  1. cmd/metrics-v3-system-network.go

    	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))
    		m.Set(internodeSentBytesTotal, float64(connStats.internodeOutputBytes))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	"github.com/prometheus/client_golang/prometheus"
    )
    
    // connStats - Network statistics
    // Count total input/output transferred bytes during
    // the server's life.
    type connStats struct {
    	internodeInputBytes  uint64
    	internodeOutputBytes uint64
    	s3InputBytes         uint64
    	s3OutputBytes        uint64
    }
    
    // Increase internode total input bytes
    func (s *connStats) incInternodeInputBytes(n int64) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/metrics-v3-api.go

    //
    // This is a `MetricsLoaderFn`.
    func loadAPIRequestsNetworkMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	connStats := globalConnStats.toServerConnStats()
    	m.Set(apiTrafficSentBytes, float64(connStats.s3OutputBytes), "type", "s3")
    	m.Set(apiTrafficRecvBytes, float64(connStats.s3InputBytes), "type", "s3")
    	return nil
    }
    
    // Metric Descriptions for bucket level S3 metrics.
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/metrics.go

    			nil, nil),
    		prometheus.CounterValue,
    		float64(connStats.internodeOutputBytes),
    	)
    
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(interNodeNamespace, "rx", "bytes_total"),
    			"Total number of internode bytes received by current MinIO server instance",
    			nil, nil),
    		prometheus.CounterValue,
    		float64(connStats.internodeInputBytes),
    	)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    //lint:ignore U1000 This is used by tests.
    func (m *Manager) debugMsg(d debugMsg, args ...any) {
    	for _, c := range m.targets {
    		c.debugMsg(d, args...)
    	}
    }
    
    // ConnStats returns the connection statistics for all connections.
    func (m *Manager) ConnStats() madmin.RPCMetrics {
    	var res madmin.RPCMetrics
    	for _, c := range m.targets {
    		t := c.Stats()
    		res.Merge(&t)
    	}
    	return res
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. cmd/metrics-realtime.go

    		}
    	}
    	if types.Contains(madmin.MetricsRPC) {
    		gr := globalGrid.Load()
    		if gr == nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: Grid not initialized", byHostName))
    		} else {
    			stats := gr.ConnStats()
    			m.Aggregated.RPC = &stats
    		}
    	}
    	// Add types...
    
    	// ByHost is a shallow reference, so careful about sharing.
    	m.ByHost = map[string]madmin.Metrics{byHostName: m.Aggregated}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    				Value:       float64(connStats.internodeOutputBytes),
    			})
    			metrics = append(metrics, MetricV2{
    				Description: getInterNodeReceivedBytesMD(),
    				Value:       float64(connStats.internodeInputBytes),
    			})
    		}
    		metrics = append(metrics, MetricV2{
    			Description: getS3SentBytesMD(),
    			Value:       float64(connStats.s3OutputBytes),
    		})
    		metrics = append(metrics, MetricV2{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top