modules

Documentation

Index

• Variables
• type Generic
  • func (g *Generic) AddMeasurements()
  • func (g *Generic) CollectMetrics() (map[string]float64, error)
  • func (g *Generic) StartMeasurement(path string) error
• type MOT
  • func (m *MOT) AddMeasurements()
  • func (m *MOT) CollectMetrics() (map[string]float64, error)
  • func (m *MOT) StartMeasurement(path string) error
• type Module
  • func NewGeneric(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module
  • func NewMOT(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module
  • func NewScript(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module
• type Script
  • func (s *Script) AddMeasurements()
  • func (s *Script) CollectMetrics() (map[string]float64, error)
  • func (s *Script) StartMeasurement(path string) error

Variables

var Modules map[string]func(config.Logger, config.EndpointConfig, chan []byte) Module = make(map[string]func(config.Logger, config.EndpointConfig, chan []byte) Module)

Types

type Generic

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

func (*Generic) AddMeasurements

func (g *Generic) AddMeasurements()

func (*Generic) CollectMetrics

func (g *Generic) CollectMetrics() (map[string]float64, error)

func (*Generic) StartMeasurement

func (g *Generic) StartMeasurement(path string) error

type MOT

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

func (*MOT) AddMeasurements

func (m *MOT) AddMeasurements()

func (*MOT) CollectMetrics

func (m *MOT) CollectMetrics() (map[string]float64, error)

func (*MOT) StartMeasurement

func (m *MOT) StartMeasurement(path string) error

type Module

type Module interface {
	StartMeasurement(path string) error
	AddMeasurements()
	CollectMetrics() (map[string]float64, error)
}

func NewGeneric

func NewGeneric(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module

func NewMOT

func NewMOT(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module

func NewScript

func NewScript(log config.Logger, cfg config.EndpointConfig, input chan []byte) Module

type Script

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

func (*Script) AddMeasurements

func (s *Script) AddMeasurements()

func (*Script) CollectMetrics

func (s *Script) CollectMetrics() (map[string]float64, error)

func (*Script) StartMeasurement

func (s *Script) StartMeasurement(path string) error