influx_cache

Documentation

Index

• type CachingTransport
  • func (t *CachingTransport) RoundTrip(req *http.Request) (*http.Response, error)
• type InfluxCache
  • func (h *InfluxCache) Close() error
  • func (h *InfluxCache) Connect() error
  • func (h *InfluxCache) Description() string
  • func (h *InfluxCache) Gather(_ telegraf.Accumulator) error
  • func (h *InfluxCache) Run(msgbus *pubsub.PubSub) error
  • func (h *InfluxCache) SampleConfig() string
  • func (h *InfluxCache) SetParser(p parsers.Parser)
  • func (h *InfluxCache) Start(acc telegraf.Accumulator) error
  • func (h *InfluxCache) Stop()
• type QueryMatchEntry
• type TimeFunc

Types

type CachingTransport

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

func (*CachingTransport) RoundTrip

func (t *CachingTransport) RoundTrip(req *http.Request) (*http.Response, error)

type InfluxCache

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

func (*InfluxCache) Close

func (h *InfluxCache) Close() error

func (*InfluxCache) Connect

func (h *InfluxCache) Connect() error

func (*InfluxCache) Description

func (h *InfluxCache) Description() string

func (*InfluxCache) Gather

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

func (*InfluxCache) Run

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

func (*InfluxCache) SampleConfig

func (h *InfluxCache) SampleConfig() string

func (*InfluxCache) SetParser

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

func (*InfluxCache) Start

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

func (*InfluxCache) Stop

func (h *InfluxCache) Stop()

type QueryMatchEntry

type QueryMatchEntry struct {
	QueryMatch string
	ClearEvery string
	// contains filtered or unexported fields
}

type TimeFunc

type TimeFunc func() time.Time