metrics

Documentation

Index

• type CacheItem
• type Collector
  • func NewCollector(defaultTimeout time.Duration, possibleMetrics []config.MetricConfig, ...) Collector
• type Extractor
  • func NewJSONObjectExtractor(p Parser) Extractor
  • func NewMetricPerTopicExtractor(p Parser, metricNameRegex *config.Regexp) Extractor
• type Ingest
  • func NewIngest(collector Collector, extractor Extractor, deviceIDRegex *config.Regexp) *Ingest
  • func (i *Ingest) Collect(metrics chan<- prometheus.Metric)
  • func (i *Ingest) Collector() prometheus.Collector
  • func (i *Ingest) ConnectionLostHandler(client mqtt.Client, err error)
  • func (i *Ingest) CountStoreError(topic string)
  • func (i *Ingest) CountSuccess(topic string)
  • func (i *Ingest) Describe(desc chan<- *prometheus.Desc)
  • func (i *Ingest) OnConnectHandler(client mqtt.Client)
  • func (i *Ingest) SetupSubscriptionHandler(errChan chan<- error) mqtt.MessageHandler
• type MemoryCachedCollector
  • func (c *MemoryCachedCollector) Collect(mc chan<- prometheus.Metric)
  • func (c *MemoryCachedCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *MemoryCachedCollector) Observe(deviceID string, collection MetricCollection)
• type Metric
• type MetricCollection
• type Parser
  • func NewParser(metrics []config.MetricConfig, separator string) Parser

Types

type CacheItem

type CacheItem struct {
	DeviceID string
	Metric   Metric
}

type Collector

type Collector interface {
	prometheus.Collector
	Observe(deviceID string, collection MetricCollection)
}

func NewCollector

func NewCollector(defaultTimeout time.Duration, possibleMetrics []config.MetricConfig, logger *zap.Logger) Collector

type Extractor

type Extractor func(topic string, payload []byte, deviceID string) (MetricCollection, error)

func NewJSONObjectExtractor

func NewJSONObjectExtractor(p Parser) Extractor

func NewMetricPerTopicExtractor

func NewMetricPerTopicExtractor(p Parser, metricNameRegex *config.Regexp) Extractor

type Ingest

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

func NewIngest

func NewIngest(collector Collector, extractor Extractor, deviceIDRegex *config.Regexp) *Ingest

func (*Ingest) Collect

func (i *Ingest) Collect(metrics chan<- prometheus.Metric)

func (*Ingest) Collector

func (i *Ingest) Collector() prometheus.Collector

func (*Ingest) ConnectionLostHandler

func (i *Ingest) ConnectionLostHandler(client mqtt.Client, err error)

func (*Ingest) CountStoreError

func (i *Ingest) CountStoreError(topic string)

func (*Ingest) CountSuccess

func (i *Ingest) CountSuccess(topic string)

func (*Ingest) Describe

func (i *Ingest) Describe(desc chan<- *prometheus.Desc)

func (*Ingest) OnConnectHandler

func (i *Ingest) OnConnectHandler(client mqtt.Client)

func (*Ingest) SetupSubscriptionHandler

func (i *Ingest) SetupSubscriptionHandler(errChan chan<- error) mqtt.MessageHandler

type MemoryCachedCollector

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

func (*MemoryCachedCollector) Collect

func (c *MemoryCachedCollector) Collect(mc chan<- prometheus.Metric)

func (*MemoryCachedCollector) Describe

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

func (*MemoryCachedCollector) Observe

func (c *MemoryCachedCollector) Observe(deviceID string, collection MetricCollection)

type Metric

type Metric struct {
	Description *prometheus.Desc
	Value       float64
	ValueType   prometheus.ValueType
	IngestTime  time.Time
	Topic       string
}

type MetricCollection

type MetricCollection []Metric

type Parser

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

func NewParser

func NewParser(metrics []config.MetricConfig, separator string) Parser