freepsflux

Documentation

Index

• Variables
• type FreepsFlux
  • func NewFreepsFlux(conf *FreepsFluxConfig, f *freepslib.Freeps) (*FreepsFlux, error)
  • func (ff *FreepsFlux) DeviceListToLineProtocol(devl *freepslib.AvmDeviceList, mTime time.Time) (string, error)
  • func (ff *FreepsFlux) DeviceListToPoints(devl *freepslib.AvmDeviceList, mTime time.Time, f func(*write.Point)) error
  • func (ff *FreepsFlux) InitInflux(reinit bool) error
  • func (ff *FreepsFlux) MetricsToLineProtocol(met *freepslib.FritzBoxMetrics, mTime time.Time) (string, error)
  • func (ff *FreepsFlux) MetricsToPoints(met *freepslib.FritzBoxMetrics, mTime time.Time, f func(*write.Point))
  • func (ff *FreepsFlux) NetDeviceListToLineProtocol(resp *freepslib.AvmDataResponse, mTime time.Time) (string, error)
  • func (ff *FreepsFlux) NetDeviceListToPoints(resp *freepslib.AvmDataResponse, mTime time.Time, f func(*write.Point)) error
  • func (ff *FreepsFlux) Push() error
  • func (ff *FreepsFlux) PushFields(measurement string, tags map[string]string, fields map[string]interface{}) error
  • func (ff *FreepsFlux) PushFreepsDeviceList(devl *freepslib.AvmDeviceList) (error, string)
  • func (ff *FreepsFlux) PushFreepsMetrics(met *freepslib.FritzBoxMetrics) (error, string)
  • func (ff *FreepsFlux) PushFreepsNetDeviceList(devl *freepslib.AvmDataResponse) (error, string)
• type FreepsFluxConfig
• type InfluxdbConfig

Variables

var DefaultConfig = FreepsFluxConfig{[]InfluxdbConfig{}, false}

Types

type FreepsFlux

type FreepsFlux struct {
	Verbose bool
	// contains filtered or unexported fields
}

func NewFreepsFlux

func NewFreepsFlux(conf *FreepsFluxConfig, f *freepslib.Freeps) (*FreepsFlux, error)

func (*FreepsFlux) DeviceListToLineProtocol

func (ff *FreepsFlux) DeviceListToLineProtocol(devl *freepslib.AvmDeviceList, mTime time.Time) (string, error)

func (*FreepsFlux) DeviceListToPoints

func (ff *FreepsFlux) DeviceListToPoints(devl *freepslib.AvmDeviceList, mTime time.Time, f func(*write.Point)) error

func (*FreepsFlux) InitInflux

func (ff *FreepsFlux) InitInflux(reinit bool) error

func (*FreepsFlux) MetricsToLineProtocol

func (ff *FreepsFlux) MetricsToLineProtocol(met *freepslib.FritzBoxMetrics, mTime time.Time) (string, error)

func (*FreepsFlux) MetricsToPoints

func (ff *FreepsFlux) MetricsToPoints(met *freepslib.FritzBoxMetrics, mTime time.Time, f func(*write.Point))

func (*FreepsFlux) NetDeviceListToLineProtocol

func (ff *FreepsFlux) NetDeviceListToLineProtocol(resp *freepslib.AvmDataResponse, mTime time.Time) (string, error)

func (*FreepsFlux) NetDeviceListToPoints

func (ff *FreepsFlux) NetDeviceListToPoints(resp *freepslib.AvmDataResponse, mTime time.Time, f func(*write.Point)) error

func (*FreepsFlux) Push

func (ff *FreepsFlux) Push() error

func (*FreepsFlux) PushFields

func (ff *FreepsFlux) PushFields(measurement string, tags map[string]string, fields map[string]interface{}) error

func (*FreepsFlux) PushFreepsDeviceList

func (ff *FreepsFlux) PushFreepsDeviceList(devl *freepslib.AvmDeviceList) (error, string)

func (*FreepsFlux) PushFreepsMetrics

func (ff *FreepsFlux) PushFreepsMetrics(met *freepslib.FritzBoxMetrics) (error, string)

func (*FreepsFlux) PushFreepsNetDeviceList

func (ff *FreepsFlux) PushFreepsNetDeviceList(devl *freepslib.AvmDataResponse) (error, string)

type FreepsFluxConfig

type FreepsFluxConfig struct {
	InfluxdbConnections []InfluxdbConfig
	IgnoreNotPresent    bool
}

type InfluxdbConfig

type InfluxdbConfig struct {
	URL    string
	Token  string
	Org    string
	Bucket string
}