internal

Documentation

Index

• type ApiMetrics
  • func GetApiMetrics() *ApiMetrics
  • func (m *ApiMetrics) AuthFailure()
  • func (m *ApiMetrics) JobsAcked(topic string)
  • func (m *ApiMetrics) JobsDropped(topic string)
  • func (m *ApiMetrics) JobsPushed(topic string)
• type ClusterMetrics
  • func GetClusterMetrics() *ClusterMetrics
  • func (m *ClusterMetrics) AddBytesReceived(bytes uint64)
  • func (m *ClusterMetrics) AddBytesSent(bytes uint64)
  • func (m *ClusterMetrics) ConnectionAccepted()
  • func (m *ClusterMetrics) ConnectionDropped()
  • func (m *ClusterMetrics) ConnectionError()
  • func (m *ClusterMetrics) ConnectionOpened()
  • func (m *ClusterMetrics) ConnectionRejected()
  • func (m *ClusterMetrics) LeaderChanged()
  • func (m *ClusterMetrics) MessageReceived()
  • func (m *ClusterMetrics) MessageSent()
  • func (m *ClusterMetrics) ReceiveError()
  • func (m *ClusterMetrics) SendError()

Types

type ApiMetrics

type ApiMetrics struct {
	// HTTP metrics
	HTTPRequestsTotal   *prometheus.CounterVec
	HTTPRequestDuration *prometheus.HistogramVec

	// WebSocket metrics
	WebSocketConnections prometheus.Gauge

	// Job metrics - per topic
	JobsPushedPerTopic  *prometheus.CounterVec
	JobsAckedPerTopic   *prometheus.CounterVec
	JobsDroppedPerTopic *prometheus.CounterVec

	// Auth metrics
	AuthFailuresTotal prometheus.Counter
}

============================================================================= ProxyApi Metrics =============================================================================

func GetApiMetrics

func GetApiMetrics() *ApiMetrics

func (*ApiMetrics) AuthFailure

func (m *ApiMetrics) AuthFailure()

Auth metrics methods

func (*ApiMetrics) JobsAcked

func (m *ApiMetrics) JobsAcked(topic string)

func (*ApiMetrics) JobsDropped

func (m *ApiMetrics) JobsDropped(topic string)

func (*ApiMetrics) JobsPushed

func (m *ApiMetrics) JobsPushed(topic string)

Job metrics methods

type ClusterMetrics

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

ClusterMetrics caches metric references for cluster-level operations

func GetClusterMetrics

func GetClusterMetrics() *ClusterMetrics

GetClusterMetrics returns the singleton ClusterMetrics instance

func (*ClusterMetrics) AddBytesReceived

func (m *ClusterMetrics) AddBytesReceived(bytes uint64)

func (*ClusterMetrics) AddBytesSent

func (m *ClusterMetrics) AddBytesSent(bytes uint64)

func (*ClusterMetrics) ConnectionAccepted

func (m *ClusterMetrics) ConnectionAccepted()

func (*ClusterMetrics) ConnectionDropped

func (m *ClusterMetrics) ConnectionDropped()

func (*ClusterMetrics) ConnectionError

func (m *ClusterMetrics) ConnectionError()

func (*ClusterMetrics) ConnectionOpened

func (m *ClusterMetrics) ConnectionOpened()

Connection methods

func (*ClusterMetrics) ConnectionRejected

func (m *ClusterMetrics) ConnectionRejected()

func (*ClusterMetrics) LeaderChanged

func (m *ClusterMetrics) LeaderChanged()

Condition methods

func (*ClusterMetrics) MessageReceived

func (m *ClusterMetrics) MessageReceived()

func (*ClusterMetrics) MessageSent

func (m *ClusterMetrics) MessageSent()

Request/Response methods

func (*ClusterMetrics) ReceiveError

func (m *ClusterMetrics) ReceiveError()

func (*ClusterMetrics) SendError

func (m *ClusterMetrics) SendError()