metrics

Documentation

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.