flumewater

Documentation

Index

• Constants
• type FlumeQueryRequest
• type FlumeWater
  • func (fw *FlumeWater) Description() string
  • func (fw *FlumeWater) Gather(a telegraf.Accumulator) error
  • func (fw *FlumeWater) SampleConfig() string
  • func (fw *FlumeWater) Stop()

Constants

const MetricName = "flume_water"

Types

type FlumeQueryRequest

type FlumeQueryRequest struct {
	Bucket          string `json:"bucket" toml:"bucket"`
	GroupMultiplier int    `json:"group_multiplier,omitempty" toml:"group_multiplier"`
	SinceDatetime   string `json:"since_datetime" toml:"since_datetime"`
	UntilDatetime   string `json:"until_datetime,omitempty" toml:"until_datetime"`
	Operation       string `json:"operation,omitempty" toml:"operation"`
	Units           string `json:"units,omitempty" toml:"units"`
	SortDirection   string `json:"sort_direction,omitempty" toml:"sort_direction"`
	RequestID       string `json:"request_id" toml:"request_id"`
}

type FlumeWater

type FlumeWater struct {
	ClientID     string `toml:"client_id"`
	ClientSecret string `toml:"client_secret"`
	Username     string `toml:"username"`
	Password     string `toml:"password"`
	DeviceID     string `toml:"device_id"`
	LookbackMins int    `toml:"lookback_mins"`
	Units        string `toml:"units"`

	Queries []flume.FlumeWaterQuery `toml:"query"`

	Log telegraf.Logger `toml:"-"`
	// contains filtered or unexported fields
}

func (*FlumeWater) Description

func (fw *FlumeWater) Description() string

func (*FlumeWater) Gather

func (fw *FlumeWater) Gather(a telegraf.Accumulator) error

func (*FlumeWater) SampleConfig

func (fw *FlumeWater) SampleConfig() string

func (*FlumeWater) Stop

func (fw *FlumeWater) Stop()