metric

Documentation

Index

• type ChannelCollector
  • func (cc ChannelCollector) Record(datum Datum)
• type Collector
• type Datum
  • func (m Datum) ToInfluxDBWireProtocol() (string, error)
• type MetricTagOverrideCollector
  • func (collector MetricTagOverrideCollector) Record(datum Datum)

Types

type ChannelCollector

type ChannelCollector chan<- Datum

ChannelCollector is a collector that sends data directly to a chan. If the chan is full, the collector will block.

func (ChannelCollector) Record

func (cc ChannelCollector) Record(datum Datum)

type Collector

type Collector interface {
	Record(datum Datum)
}

Collector is something that a source invokes to send metrics.

type Datum

type Datum struct {
	Name   string
	Time   time.Time
	Tags   map[string]string
	Fields map[string]interface{}
}

Datum is a data point extracted by a source plugin. Its shape follows the InfluxDB Wire Protocol.

func (Datum) ToInfluxDBWireProtocol

func (m Datum) ToInfluxDBWireProtocol() (string, error)

type MetricTagOverrideCollector

type MetricTagOverrideCollector struct {
	Inner      Collector
	MetricTags map[string]string
}

MetricTagOverrideCollector wraps another Collector, but modifies the data passing through by appending or overriding the given MetricTags.

func (MetricTagOverrideCollector) Record

func (collector MetricTagOverrideCollector) Record(datum Datum)