metrics

Documentation

Index

• Variables
• func RegisterMetrics(globalLabels prometheus.Labels)
• func Reset()
• 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
	MessagesConsumedOutOfOrder *prometheus.CounterVec
	PublishingLatency          *prometheus.SummaryVec
	EndToEndLatency            *prometheus.SummaryVec
)

Functions

func RegisterMetrics

func RegisterMetrics(globalLabels prometheus.Labels)

func Reset

func Reset()

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()