kinesis

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 2, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Description

func Description() string

Description returns a short description of the plugin

func SampleConfig

func SampleConfig() string

SampleConfig will return a sample configuration that can be used.

Types

type KinesisOutput

type KinesisOutput struct {
	Region      string `toml:"region"`
	AccessKey   string `toml:"access_key"`
	SecretKey   string `toml:"secret_key"`
	RoleARN     string `toml:"role_arn"`
	Profile     string `toml:"profile"`
	Filename    string `toml:"shared_credential_file"`
	Token       string `toml:"token"`
	EndpointURL string `toml:"endpoint_url"`

	StreamName         string                  `toml:"streamname"`
	Partition          *Partition              `toml:"partition"`
	Debug              bool                    `toml:"debug"`
	AggregateMetrics   bool                    `toml:"aggregate_metrics"`
	OverrideShardCount int                     `toml:"override_shard_count"`
	ContentEncoding    string                  `toml:"content_encoding"`
	Formatting         *serializerclone.Config `toml:"formatting"`
	// contains filtered or unexported fields
}

KinesisOutput describes a telegraf kinesis output plugin

func NewKinesisOutput

func NewKinesisOutput(configFilePath string) (*KinesisOutput, error)

NewKinesisOutput returns a Kinesis Output that is ready to connect and be used to send data. An error is also returned if something goes wrong.

func (*KinesisOutput) Close

func (k *KinesisOutput) Close() error

Close does nothing but is required by the telegraf plugin interface

func (*KinesisOutput) Connect

func (k *KinesisOutput) Connect() error

Connect will establish a connection to AWS Kinesis and make sure there are shards ready to collect data.

func (*KinesisOutput) Write

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

type Partition

type Partition struct {
	Method  string `toml:"method"`
	Key     string `toml:"key"`
	Default string `toml:"default"`
}

Partition is used to detect what type of partition key you would like to use.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL