timestream

package
v0.0.0-...-aec62d2 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2021 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBatchFactory

func NewBatchFactory() *batchFactory

NewBatchFactory returns a object pool backed batch factory that produces batches that hold timestream deserialized points

func NewTarget

func NewTarget() targets.ImplementedTarget

func OpenAWSSession

func OpenAWSSession(awsRegion *string, timeout time.Duration) (*session.Session, error)

Types

type SpecificConfig

type SpecificConfig struct {
	UseCommonAttributes      bool   `yaml:"use-common-attributes" mapstructure:"use-common-attributes"`
	AwsRegion                string `yaml:"aws-region" mapstructure:"aws-region"`
	HashProperty             string `yaml:"hash-property" mapstructure:"hash-property"`
	UseCurrentTime           bool   `yaml:"use-current-time" mapstructure:"use-current-time"`
	MagStoreRetentionInDays  int64  `yaml:"mag-store-retention-in-days" mapstructure:"mag-store-retention-in-days"`
	MemStoreRetentionInHours int64  `yaml:"mem-store-retention-in-hours" mapstructure:"mem-store-retention-in-hours"`
}

Jump to

Keyboard shortcuts

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