metrics

Documentation

Index

• Constants
• func RunServer(ctx context.Context) (<-chan error, <-chan struct{})
• type Adder
• type Container
  • func NewMetrics(listURL []*url.URL) Container
  • func (c Container) GetMetric(key, typeMetric string) (Adder, error)
  • func (c Container) IncrementMetric(key, metricType string) error

Constants

const (
	//MetricTypeFeed defines type for feed metric
	MetricTypeFeed = "feed"
	//MetricTypeTotal defines type for total metric
	MetricTypeTotal = "total"
	//MetricTypeFailed defines type for failed metric
	MetricTypeFailed = "failed"
	//MetricTypeSucceeded defines type for succeeded metric
	MetricTypeSucceeded = "succeeded"
)

const (
	//MetricsAddressCtxKey defines key for context value of the addres for server
	MetricsAddressCtxKey = "metricsServerAddress"
)

Functions

func RunServer

func RunServer(ctx context.Context) (<-chan error, <-chan struct{})

RunServer - run server on the provided address and expose /metrics endpoint return 2 channels: first for getting error messages and second channel idenifies status of the server if second channel will be closed - server exited Context should contain under key "serverAddressMetrics" string with local address to which it will be binded If context cancelled - server also exits

Types

type Adder

type Adder interface {
	Add(float64)
}

Adder add value from param to internal value Gauge and Counter both support method Add the only difference is that val could not be negative for Counter those metrics are thread safe and use package atomic no need to add another atomic operations

type Container

type Container map[string]map[string]Adder

Container holds all metrics

func NewMetrics

func NewMetrics(listURL []*url.URL) Container

NewMetrics creates container with all metrics per feed

func (Container) GetMetric

func (c Container) GetMetric(key, typeMetric string) (Adder, error)

GetMetric returns metric configured. If metric could not be found returns error.

func (Container) IncrementMetric

func (c Container) IncrementMetric(key, metricType string) error

IncrementMetric increments metric