metrics

Jun 28, 2022

Changes in this version

type Batch

+ LastSendAt time.Time

+ func (b *Batch) MarshalJSON() ([]byte, error)

+ func (b *Batch) Size() int

+ type Service interface

+ AddMetric func(Metric) error

+ Collect func() error

+ ForceAddMetric func(Metric) error

+ Init func() error

+ Shutdown func() error

May 5, 2022

Changes in this version

type PrometheusService

+ Prefix string

Apr 20, 2022

Changes in this version

type PrometheusService

+ func (ps *PrometheusService) SystemMetrics() error

Apr 18, 2022

Changes in this version

type PrometheusService

+ func (ps *PrometheusService) ForceAddMetric(metric Metric)

Apr 18, 2022

Changes in this version

+ type Batch struct

+ MaxSize int

+ func NewBatch() Batch

+ func (b *Batch) AddMetric(metric Metric)

+ func (b *Batch) Reset()

+ type Labels map[string]string

+ func (l Labels) With(additional map[string]string) Labels

+ type Metric struct

+ Labels Labels

+ Name string

+ Type MetricType

+ Value float64

+ type MetricType string

+ const CounterMetricType

+ const GaugeMetricType

+ type PrometheusService struct

+ BatchSize int

+ BatchTTL time.Duration

+ Channel *amqp.Channel

+ DefaultLabels Labels

+ Exchange string

+ Logger *zap.Logger

+ MessageTTL int

+ Period time.Duration

+ Queue string

+ func NewPrometheusService(logger *zap.Logger, channel *amqp.Channel) *PrometheusService

+ func (ps *PrometheusService) AddMetric(metric Metric)

+ func (ps *PrometheusService) Close()

+ func (ps *PrometheusService) Counter(metric string, labels Labels)

+ func (ps *PrometheusService) Duration(since time.Time, metric string, labels Labels)

+ func (ps *PrometheusService) Init() error

+ func (ps *PrometheusService) Monitor()

+ func (ps *PrometheusService) SendBatch()