metrics

Documentation

Index

• Variables
• func ListenAndServe()
• type QueueMetricsMap
  • func NewQueueMetricsMap() *QueueMetricsMap
  • func (oldestMap *QueueMetricsMap) UpdateOldestElementMap(data map[string]int64)
  • func (oldestMap *QueueMetricsMap) UpdateTotalElementsMap(data map[string]int64)
• type WrappedRegistry
  • func NewWrappedRegistry(promRegistry *prom.Registry, labels ...*dto.LabelPair) *WrappedRegistry
  • func (wr *WrappedRegistry) Gather() ([]*dto.MetricFamily, error)
  • func (wr *WrappedRegistry) MustRegister(collector ...prom.Collector)
  • func (wr *WrappedRegistry) Register(collector prom.Collector) error
  • func (wr *WrappedRegistry) Unregister(collector prom.Collector) bool

Variables

var (
	MetricsMap *QueueMetricsMap

	// Keep tracking of features used by clients to be able to deprecate them
	CodeUsage metric.Int64Counter

	// Housekeepermetric
	HousekeeperExceedingStorageRemoved metric.Int64Counter
	HousekeeperExceedingCacheRemoved   metric.Int64Counter
	HousekeeperTTLStorageRemoved       metric.Int64Counter
	HousekeeperTTLCacheRemoved         metric.Int64Counter
	HousekeeperUnlock                  metric.Int64Counter
	HousekeeperTaskLatency             metric.Int64Histogram
	HousekeeperOldestMessage           metric.Int64ObservableGauge
	HousekeeperTotalElements           metric.Int64ObservableGauge

	// Message Pool
	QueueTimeout           metric.Int64Counter
	QueueAck               metric.Int64Counter
	QueueNack              metric.Int64Counter
	QueueEmptyQueue        metric.Int64Counter
	QueueEmptyQueueStorage metric.Int64Counter
	QueueNotFoundInStorage metric.Int64Counter

	// Storage
	StorageLatency metric.Int64Histogram

	// Cache
	CacheLatency metric.Int64Histogram

	// Auditor
	AuditorAddToStoreLatency metric.Int64Histogram
	AuditorStoreLatency      metric.Int64Histogram
)

Functions

func ListenAndServe

func ListenAndServe()

Types

type QueueMetricsMap

type QueueMetricsMap struct {
	OldestElement map[string]int64
	TotalElements map[string]int64
}

Type to hold map of oldest queue elements

func NewQueueMetricsMap

func NewQueueMetricsMap() *QueueMetricsMap

func (*QueueMetricsMap) UpdateOldestElementMap

func (oldestMap *QueueMetricsMap) UpdateOldestElementMap(data map[string]int64)

func (*QueueMetricsMap) UpdateTotalElementsMap

func (oldestMap *QueueMetricsMap) UpdateTotalElementsMap(data map[string]int64)

type WrappedRegistry

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

func NewWrappedRegistry

func NewWrappedRegistry(promRegistry *prom.Registry, labels ...*dto.LabelPair) *WrappedRegistry

func (*WrappedRegistry) Gather

func (wr *WrappedRegistry) Gather() ([]*dto.MetricFamily, error)

func (*WrappedRegistry) MustRegister

func (wr *WrappedRegistry) MustRegister(collector ...prom.Collector)

func (*WrappedRegistry) Register

func (wr *WrappedRegistry) Register(collector prom.Collector) error

func (*WrappedRegistry) Unregister

func (wr *WrappedRegistry) Unregister(collector prom.Collector) bool