metrics

package

v0.1.0 Latest Latest Go to latest Published: May 24, 2022 License: Apache-2.0 Imports: 8 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/christiangda/mq-to-db

Links

Open Source Insights

Documentation ¶

Index ¶

type DBMetricsCollector
- func NewDBMetricsCollector(namespace, subsystem string, db DBStatsGetter) *DBMetricsCollector
- func (c *DBMetricsCollector) Collect(ch chan<- prometheus.Metric)
- func (c *DBMetricsCollector) Describe(ch chan<- *prometheus.Desc)
type DBStatsGetter
type Metrics
- func New(c *config.Config) *Metrics
- func (m Metrics) EnableDBStats(db storage.Store)
- func (m Metrics) GetHandler() http.Handler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DBMetricsCollector ¶

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

DBMetricsCollector ...

func NewDBMetricsCollector ¶

func NewDBMetricsCollector(namespace, subsystem string, db DBStatsGetter) *DBMetricsCollector

NewDBMetricsCollector return all the metrics

func (*DBMetricsCollector) Collect ¶

func (c *DBMetricsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface

func (*DBMetricsCollector) Describe ¶

func (c *DBMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface

type DBStatsGetter ¶

type DBStatsGetter interface {
	Stats() sql.DBStats
}

DBStatsGetter is an interface that gets sql.DBStats. It's implemented by e.g. *sql.DB or *sqlx.DB.

type Metrics ¶

type Metrics struct {

	// Global
	Up   prometheus.Gauge
	Info prometheus.Gauge

	// Consumers
	ConsumerRunning  *prometheus.GaugeVec
	ConsumerMessages *prometheus.CounterVec

	// Storage Workers
	StorageWorkerRunning            *prometheus.GaugeVec
	StorageWorkerMessages           *prometheus.CounterVec
	StorageWorkerProcessingDuration *prometheus.HistogramVec

	// Storer
	RepositoryMessagesTotal              prometheus.Counter
	RepositoryMessagesErrorsTotal        prometheus.Counter
	RepositorySQLMessagesTotal           prometheus.Counter
	RepositorySQLMessagesErrorsTotal     prometheus.Counter
	RepositorySQLMessagesToDBTotal       prometheus.Counter
	RepositorySQLMessagesToDBErrorsTotal prometheus.Counter
	RepositoryMessagesAckTotal           prometheus.Counter
	RepositoryMessagesRejectedTotal      prometheus.Counter

	// Storage
	StoragePingTotal        prometheus.Counter
	StoragePingTimeOutTotal prometheus.Counter
	StorageExecTotal        prometheus.Counter
	StorageExecTimeOutTotal prometheus.Counter
	// contains filtered or unexported fields
}

Metrics ...

func New ¶

func New(c *config.Config) *Metrics

New return all the metrics

func (Metrics) EnableDBStats ¶

func (m Metrics) EnableDBStats(db storage.Store)

EnableDBStats enable the database/sql stats metrics

func (Metrics) GetHandler ¶

func (m Metrics) GetHandler() http.Handler

GetHandler return the http handler for metrics endpoints

Source Files ¶

View all Source files

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