firehose

Documentation

Index

• func SampleConfig() string
• type Output
  • func NewOutput(configFilePath string) (*Output, error)
  • func (k *Output) Close() error
  • func (k *Output) Connect() error
  • func (k *Output) Write(metrics []telegraf.Metric) error

Functions

func SampleConfig

func SampleConfig() string

Types

type Output

type Output struct {
	StreamName string               `toml:"streamname"`
	Debug      bool                 `toml:"debug"`
	Format     serializer.Formatter `toml:"format"`

	internalaws.CredentialConfig
	// contains filtered or unexported fields
}

func NewOutput

func NewOutput(configFilePath string) (*Output, error)

func (*Output) Close

func (k *Output) Close() error

func (*Output) Connect

func (k *Output) Connect() error

func (*Output) Write

func (k *Output) Write(metrics []telegraf.Metric) error