metrics

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 13, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PrometheusMetrics

type PrometheusMetrics struct {
	EnqueueTotal    *prometheus.CounterVec
	DequeueTotal    *prometheus.CounterVec
	AckTotal        *prometheus.CounterVec
	NackTotal       *prometheus.CounterVec
	Messages        *prometheus.GaugeVec
	UnackedMessages *prometheus.GaugeVec
	ReadyMessages   *prometheus.GaugeVec
	Registry        *prometheus.Registry
}

func NewPrometheusMetrics

func NewPrometheusMetrics(registry prometheus.Registerer, namespace, subsystem string) *PrometheusMetrics

type QueueStats

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

func NewQueueStats

func NewQueueStats(windowSize int) *QueueStats

func (*QueueStats) GetRPS

func (rc *QueueStats) GetRPS() *Stats

func (*QueueStats) IncrementAck

func (rc *QueueStats) IncrementAck()

func (*QueueStats) IncrementDequeue

func (rc *QueueStats) IncrementDequeue()

func (*QueueStats) IncrementEnqueue

func (rc *QueueStats) IncrementEnqueue()

func (*QueueStats) IncrementNack

func (rc *QueueStats) IncrementNack()

func (*QueueStats) Start

func (rc *QueueStats) Start()

func (*QueueStats) Stop

func (rc *QueueStats) Stop()

func (*QueueStats) UpdateWindow

func (rc *QueueStats) UpdateWindow()

type Stats

type Stats struct {
	EnqueueRPS float64
	DequeueRPS float64
	AckRPS     float64
	NackRPS    float64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL