collectd

Documentation

Index

• type Checker
  • func NewChecker(logger *logrus.Logger, checks map[string]config.Check, ...) (*Checker, error)
  • func (checker *Checker) Emit(record CollectdRecord) error
  • func (checker *Checker) Start()
  • func (checker *Checker) Stop()
  • func (checker *Checker) String() string
  • func (checker *Checker) WaitForShutdown()
• type CollectdCheckerListener
• type CollectdRecord
• type TagList
• type Transformer
  • func NewTransformer(logger *logrus.Logger, tagList []string, listener CollectdCheckerListener) (*Transformer, error)
  • func (transformer *Transformer) Emit(recordSets []shared.RecordSet) error
  • func (transformer *Transformer) Start()
  • func (transformer *Transformer) Stop()
  • func (transformer *Transformer) String() string
  • func (transformer *Transformer) TransformRecord(tag string, record shared.TinyRecord, transformed *CollectdRecord) error
  • func (transformer *Transformer) WaitForShutdown()

Types

type Checker

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

func NewChecker

func NewChecker(logger *logrus.Logger, checks map[string]config.Check, transformer shared.Transformer) (*Checker, error)

func (*Checker) Emit

func (checker *Checker) Emit(record CollectdRecord) error

func (*Checker) Start

func (checker *Checker) Start()

func (*Checker) Stop

func (checker *Checker) Stop()

func (*Checker) String

func (checker *Checker) String() string

func (*Checker) WaitForShutdown

func (checker *Checker) WaitForShutdown()

type CollectdCheckerListener

type CollectdCheckerListener interface {
	Emit(record CollectdRecord) error
}

type CollectdRecord

type CollectdRecord struct {
	Tag            string
	Timestamp      uint64
	Raw            map[string]interface{}
	Host           string
	Plugin         string
	PluginInstance string
	Type           string
	TypeInstance   string
	Values         []interface{}
	DsTypes        interface{}
	DsNames        interface{}
	Interval       uint8
}

type TagList

type TagList map[string]bool

type Transformer

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

func NewTransformer

func NewTransformer(logger *logrus.Logger, tagList []string, listener CollectdCheckerListener) (*Transformer, error)

func (*Transformer) Emit

func (transformer *Transformer) Emit(recordSets []shared.RecordSet) error

func (*Transformer) Start

func (transformer *Transformer) Start()

func (*Transformer) Stop

func (transformer *Transformer) Stop()

func (*Transformer) String

func (transformer *Transformer) String() string

func (*Transformer) TransformRecord

func (transformer *Transformer) TransformRecord(tag string, record shared.TinyRecord, transformed *CollectdRecord) error

func (*Transformer) WaitForShutdown

func (transformer *Transformer) WaitForShutdown()