metrics

Documentation

Index

• Variables
• type MetricsServer
  • func GetMetricsServer() *MetricsServer
  • func (m MetricsServer) PrintMetrics()
  • func (m MetricsServer) Start()
  • func (m MetricsServer) Stop()

Variables

var (
	MessagesPublished = promauto.NewCounterVec(prometheus.CounterOpts{
		Name: "omq_messages_published_total",
		Help: "The total number of published messages"},
		[]string{
			"protocol",
		},
	)
	MessagesConsumed = promauto.NewCounterVec(prometheus.CounterOpts{
		Name: "omq_messages_consumed_total",
		Help: "The total number of consumed messages"},
		[]string{
			"protocol",
		},
	)
	PublishingLatency = promauto.NewSummaryVec(prometheus.SummaryOpts{
		Name:       "omq_publishing_latency_seconds",
		Help:       "Time from sending a message to receiving a confirmation",
		Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.95: 0.005, 0.99: 0.001},
	},
		[]string{
			"protocol",
		},
	)
	EndToEndLatency = promauto.NewSummaryVec(prometheus.SummaryOpts{
		Name:       "omq_end_to_end_latency_seconds",
		Help:       "Time from sending a message to receiving the message",
		Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.95: 0.005, 0.99: 0.001},
	},
		[]string{
			"protocol",
		},
	)
)

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