kubernetes/staging/src/k8s.io/apiserver/pkg/server/egressselector/metrics/metrics.go

const namespace …

const subsystem …

const ProtocolHTTPConnect …

const ProtocolGRPC …

const TransportTCP …

const TransportUDS …

const StageConnect …

const StageProxy …

var latencyBuckets …

var Metrics …

type DialMetrics …

// newDialMetrics create a new DialMetrics, configured with default metric names.
func newDialMetrics() *DialMetrics { … }

// Clock returns the clock.
func (m *DialMetrics) Clock() clock.Clock { … }

// SetClock sets the clock.
func (m *DialMetrics) SetClock(c clock.Clock) { … }

// Reset resets the metrics.
func (m *DialMetrics) Reset() { … }

// ObserveDialStart records the start of a dial attempt, labeled by protocol, transport.
func (m *DialMetrics) ObserveDialStart(protocol, transport string) { … }

// ObserveDialLatency records the latency of a dial, labeled by protocol, transport.
func (m *DialMetrics) ObserveDialLatency(elapsed time.Duration, protocol, transport string) { … }

// ObserveDialFailure records a failed dial, labeled by protocol, transport, and the stage the dial failed at.
func (m *DialMetrics) ObserveDialFailure(protocol, transport, stage string) { … }