timestream

Documentation

Index

• func NewBatchFactory() *batchFactory
• func NewTarget() targets.ImplementedTarget
• func OpenAWSSession(awsRegion *string, timeout time.Duration) (*session.Session, error)
• type SpecificConfig

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"`
}