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 instrument.Int64Counter

	// Housekeeper
	HousekeeperExceedingStorageRemoved instrument.Int64Counter
	HousekeeperExceedingCacheRemoved   instrument.Int64Counter
	HousekeeperTTLStorageRemoved       instrument.Int64Counter
	HousekeeperTTLCacheRemoved         instrument.Int64Counter
	HousekeeperUnlock                  instrument.Int64Counter
	HousekeeperTaskLatency             instrument.Int64Histogram
	HousekeeperOldestMessage           instrument.Int64ObservableGauge
	HousekeeperTotalElements           instrument.Int64ObservableGauge

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

	// Storage
	StorageLatency instrument.Int64Histogram

	// Cache
	CacheLatency instrument.Int64Histogram

	// Auditor
	AuditorAddToStoreLatency instrument.Int64Histogram
	AuditorStoreLatency      instrument.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