timestream

README

timestream

Simple package that provides a simple, buffered interface towards AWS timestream.

Usage:

Documentation

Index

• type TimestreamEntry
• type TimestreamState
  • func Factory(awsRegion string, awsTimestreamDbname string) TimestreamState
  • func (c *TimestreamState) CheckAndCreateTables(tables []string) error
  • func (c *TimestreamState) FlushAwsTimestreamWrites() []error
  • func (c *TimestreamState) MakeEntry(entry TimestreamEntry)

Types

type TimestreamEntry

type TimestreamEntry struct {
	Time      time.Time
	SensorId  string
	TableName string
	Value     string
}

type TimestreamState

type TimestreamState struct {
	AwsRegion           string
	AwsTimestreamDbname string
	WriteSession        *timestreamwrite.TimestreamWrite
	WriteBuffer         map[string][]*timestreamwrite.Record // a hash with table name as key.
	Transport           *http.Transport
}

func Factory

func Factory(awsRegion string, awsTimestreamDbname string) TimestreamState

func (*TimestreamState) CheckAndCreateTables

func (c *TimestreamState) CheckAndCreateTables(tables []string) error

get a list of the tables in the database and create the ones we need if they don't exist.

func (*TimestreamState) FlushAwsTimestreamWrites

func (c *TimestreamState) FlushAwsTimestreamWrites() []error

func (*TimestreamState) MakeEntry

func (c *TimestreamState) MakeEntry(entry TimestreamEntry)