collector

Documentation

Index

• type Collector
  • func New(cfg *config.Config) *Collector
  • func (c *Collector) AddTarget(tconf *config.Target, stringValueMapping map[string]map[string]int, ...) *Target
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
  • func (c *Collector) Dump() []string
  • func (c *Collector) Stop()
• type Target
  • func (t *Target) Serve(con *grpc.ClientConn)

Types

type Collector

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

Collector is a streaming telemetry data collector

func New

func New(cfg *config.Config) *Collector

New initializes a new Collector

func (*Collector) AddTarget

func (c *Collector) AddTarget(tconf *config.Target, stringValueMapping map[string]map[string]int, reconnect bool) *Target

AddTarget adds a target to the collector

func (*Collector) Collect

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

Collect collects data from the collector and send it to prometheus

func (*Collector) Describe

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

Describe is required by prometheus interface

func (*Collector) Dump

func (c *Collector) Dump() []string

Dump dumps the collectors internal state

func (*Collector) Stop

func (c *Collector) Stop()

Stop stops the collector

type Target

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

Target represents a streaming telemetry exporting network device

func (*Target) Serve

func (t *Target) Serve(con *grpc.ClientConn)

Serve is the main handling routine for a target