metrics

Documentation

Index

• Variables
• func Start(metricsPort int)
• func StartTimer(h *prometheus.HistogramVec) func(...string)

Variables

var HandlerProcessingHistogram = prometheus.NewHistogramVec(prometheus.HistogramOpts{
	Namespace: "worker",
	Name:      "handler_processing",
	Help:      "handler processing time",
}, []string{"pipe", "source", "success"})

var PipeProcessingMessagesHistogram = prometheus.NewHistogramVec(prometheus.HistogramOpts{
	Namespace: "worker",
	Name:      "pipe_processing",
	Help:      "Pipe processing messages",
}, []string{"pipe", "source", "success"})

var WorkerBatchSizeGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
	Namespace: "worker",
	Subsystem: "concurrent",
	Name:      "size",
	Help:      "concurrent message handling",
}, []string{"source"})

var WorkerMaxConcurrencyGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
	Namespace: "worker",
	Subsystem: "concurrent",
	Name:      "max",
	Help:      "max concurrent messages",
}, []string{"source"})

Functions

func Start

func Start(metricsPort int)

func StartTimer

func StartTimer(h *prometheus.HistogramVec) func(...string)