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()
Click to show internal directories.
Click to hide internal directories.