metrics

Documentation

Index

• Variables
• func RegisterMetrics(globalLabels prometheus.Labels)
• func UnregisterMetrics()
• type MetricsServer
  • func GetMetricsServer() *MetricsServer
  • func (m MetricsServer) PrintMetrics()
  • func (m MetricsServer) Start()
  • func (m MetricsServer) Stop()

Variables

var (
	MessagesPublished *prometheus.CounterVec
	MessagesConsumed  *prometheus.CounterVec
	PublishingLatency *prometheus.SummaryVec
	EndToEndLatency   *prometheus.SummaryVec
)

Functions

func RegisterMetrics

func RegisterMetrics(globalLabels prometheus.Labels)

func UnregisterMetrics

func UnregisterMetrics()

Types

type MetricsServer

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

func GetMetricsServer

func GetMetricsServer() *MetricsServer

func (MetricsServer) PrintMetrics

func (m MetricsServer) PrintMetrics()

func (MetricsServer) Start

func (m MetricsServer) Start()

func (MetricsServer) Stop

func (m MetricsServer) Stop()