collector

Documentation

Index

• func MustNewTimeConstMetric(desc *prometheus.Desc, valueType prometheus.ValueType, value float64, ...) prometheus.Metric
• func NewTimeConstMetric(desc *prometheus.Desc, valueType prometheus.ValueType, value float64, ...) (prometheus.Metric, error)
• type Collector
  • func NewCollector(cfg config.Config) *Collector
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
  • func (c *Collector) Reader(udpSock *net.UDPConn)

Functions

func MustNewTimeConstMetric

func MustNewTimeConstMetric(desc *prometheus.Desc, valueType prometheus.ValueType,
	value float64, timestampMs int64) prometheus.Metric

MustNewTimeConstMetric creates a new prometheus.Metric with a timestamp

func NewTimeConstMetric

func NewTimeConstMetric(desc *prometheus.Desc, valueType prometheus.ValueType,
	value float64, timestampMs int64) (prometheus.Metric, error)

NewTimeConstMetric creates a new prometheus.Metric with a timestamp

Types

type Collector

type Collector struct {
	Config  config.Config
	Channel chan *sample
	Samples map[string]*sample
	Mutex   *sync.Mutex
}

Collector is the main collector type

func NewCollector

func NewCollector(cfg config.Config) *Collector

NewCollector will define new NetFlow collector instance

func (*Collector) Collect

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

Collect will collect the metrics

func (*Collector) Describe

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

Describe will describe the metrics

func (*Collector) Reader

func (c *Collector) Reader(udpSock *net.UDPConn)

Reader will read NetFlow UDP packets from the socket