package metrics

import "k8s.io/apiserver/pkg/server/egressselector/metrics"

Index ¶

• Constants
• Variables
• type DialMetrics
• func (m *DialMetrics) Clock() clock.Clock
• func (m *DialMetrics) ObserveDialFailure(protocol, transport, stage string)
• func (m *DialMetrics) ObserveDialLatency(elapsed time.Duration, protocol, transport string)
• func (m *DialMetrics) ObserveDialStart(protocol, transport string)
• func (m *DialMetrics) Reset()
• func (m *DialMetrics) SetClock(c clock.Clock)

Constants ¶

const (

	// ProtocolHTTPConnect means that the proxy protocol is http-connect.
	ProtocolHTTPConnect = "http_connect"
	// ProtocolGRPC means that the proxy protocol is the GRPC protocol.
	ProtocolGRPC = "grpc"
	// TransportTCP means that the transport is TCP.
	TransportTCP = "tcp"
	// TransportUDS means that the transport is UDS.
	TransportUDS = "uds"
	// StageConnect indicates that the dial failed at establishing connection to the proxy server.
	StageConnect = "connect"
	// StageProxy indicates that the dial failed at requesting the proxy server to proxy.
	StageProxy = "proxy"
)

Variables ¶

var (

	// Metrics provides access to all dial metrics.
	Metrics = newDialMetrics()
)

Types ¶

type DialMetrics ¶

type DialMetrics struct {
	// contains filtered or unexported fields
}

DialMetrics instruments dials to proxy server with prometheus metrics.

func (*DialMetrics) Clock ¶

func (m *DialMetrics) Clock() clock.Clock

Clock returns the clock.

func (*DialMetrics) ObserveDialFailure ¶

func (m *DialMetrics) ObserveDialFailure(protocol, transport, stage string)

ObserveDialFailure records a failed dial, labeled by protocol, transport, and the stage the dial failed at.

func (*DialMetrics) ObserveDialLatency ¶

func (m *DialMetrics) ObserveDialLatency(elapsed time.Duration, protocol, transport string)

ObserveDialLatency records the latency of a dial, labeled by protocol, transport.

func (*DialMetrics) ObserveDialStart ¶

func (m *DialMetrics) ObserveDialStart(protocol, transport string)

ObserveDialStart records the start of a dial attempt, labeled by protocol, transport.

func (*DialMetrics) Reset ¶

func (m *DialMetrics) Reset()

Reset resets the metrics.

func (*DialMetrics) SetClock ¶

func (m *DialMetrics) SetClock(c clock.Clock)

SetClock sets the clock.

Source Files ¶

metrics.go