influx_bridge

Documentation

Index

• type InfluxBridge
  • func (h *InfluxBridge) Close() error
  • func (h *InfluxBridge) Connect() error
  • func (h *InfluxBridge) Description() string
  • func (h *InfluxBridge) Gather(_ telegraf.Accumulator) error
  • func (h *InfluxBridge) Run(msgbus *pubsub.PubSub) error
  • func (h *InfluxBridge) SampleConfig() string
  • func (h *InfluxBridge) SetParser(p parsers.Parser)
  • func (h *InfluxBridge) Start(acc telegraf.Accumulator) error
  • func (h *InfluxBridge) Stop()
• type QueryMatchEntry
• type TimeFunc

Types

type InfluxBridge

type InfluxBridge struct {
	Address         string
	InfluxDBAddress string `toml:"influx_db_address"`
	TLSCert         string `toml:"tls_cert"`
	TLSKey          string `toml:"tls_key"`
	QueryMatch      []QueryMatchEntry
	// contains filtered or unexported fields
}

func (*InfluxBridge) Close

func (h *InfluxBridge) Close() error

func (*InfluxBridge) Connect

func (h *InfluxBridge) Connect() error

func (*InfluxBridge) Description

func (h *InfluxBridge) Description() string

func (*InfluxBridge) Gather

func (h *InfluxBridge) Gather(_ telegraf.Accumulator) error

func (*InfluxBridge) Run

func (h *InfluxBridge) Run(msgbus *pubsub.PubSub) error

func (*InfluxBridge) SampleConfig

func (h *InfluxBridge) SampleConfig() string

func (*InfluxBridge) SetParser

func (h *InfluxBridge) SetParser(p parsers.Parser)

func (*InfluxBridge) Start

func (h *InfluxBridge) Start(acc telegraf.Accumulator) error

func (*InfluxBridge) Stop

func (h *InfluxBridge) Stop()

type QueryMatchEntry

type QueryMatchEntry struct {
	QueryMatch string
	MatchPass  []string
	MatchDrop  []string
	// contains filtered or unexported fields
}

type TimeFunc

type TimeFunc func() time.Time