metrics

Documentation

Overview

Package metrics provides implementations of prometheus.Collector to collect Asynq queue metrics.

Index

• type QueueMetricsCollector
  • func NewQueueMetricsCollector(inspector *asynq.Inspector) *QueueMetricsCollector
  • func (qmc *QueueMetricsCollector) Collect(ch chan<- prometheus.Metric)
  • func (qmc *QueueMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Types

type QueueMetricsCollector

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

QueueMetricsCollector gathers queue metrics. It implements prometheus.Collector interface.

All metrics exported from this collector have prefix "asynq".

func NewQueueMetricsCollector

func NewQueueMetricsCollector(inspector *asynq.Inspector) *QueueMetricsCollector

NewQueueMetricsCollector returns a collector that exports metrics about Asynq queues.

func (*QueueMetricsCollector) Collect

func (qmc *QueueMetricsCollector) Collect(ch chan<- prometheus.Metric)

func (*QueueMetricsCollector) Describe

func (qmc *QueueMetricsCollector) Describe(ch chan<- *prometheus.Desc)