metrics

package

v0.0.28 Latest Latest Go to latest Published: Feb 5, 2024 License: MIT Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/takenet/deckard

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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 ¶ added in v0.0.16

func ListenAndServe()

Types ¶

type QueueMetricsMap ¶ added in v0.0.17

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

Type to hold map of oldest queue elements

func NewQueueMetricsMap ¶ added in v0.0.17

func NewQueueMetricsMap() *QueueMetricsMap

func (*QueueMetricsMap) UpdateOldestElementMap ¶ added in v0.0.17

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

func (*QueueMetricsMap) UpdateTotalElementsMap ¶ added in v0.0.17

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL