metrics

Documentation

Index

• Variables
• func ListenAndServe()
• type MessagePoolMetricsMap
  • func NewMessagePoolMetricsMap() *MessagePoolMetricsMap
  • func (oldestMap *MessagePoolMetricsMap) UpdateOldestElementMap(data map[string]int64)
  • func (oldestMap *MessagePoolMetricsMap) 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 *MessagePoolMetricsMap

	// 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
	MessagePoolTimeout           instrument.Int64Counter
	MessagePoolAck               instrument.Int64Counter
	MessagePoolNack              instrument.Int64Counter
	MessagePoolEmptyQueue        instrument.Int64Counter
	MessagePoolEmptyQueueStorage instrument.Int64Counter
	MessagePoolNotFoundInStorage instrument.Int64Counter

	// Storage
	StorageLatency instrument.Int64Histogram

	// Cache
	CacheLatency instrument.Int64Histogram

	// Auditor
	AuditorAddToStoreLatency instrument.Int64Histogram
	AuditorStoreLatency      instrument.Int64Histogram
)

Functions

func ListenAndServe

func ListenAndServe()

Types

type MessagePoolMetricsMap

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

Type to hold map of oldest queue elements

func NewMessagePoolMetricsMap

func NewMessagePoolMetricsMap() *MessagePoolMetricsMap

func (*MessagePoolMetricsMap) UpdateOldestElementMap

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

func (*MessagePoolMetricsMap) UpdateTotalElementsMap

func (oldestMap *MessagePoolMetricsMap) 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