iotdb

Documentation

Index

• func NewBenchmark(dbName string, opts *LoadingOptions, dataSourceConfig *source.DataSourceConfig) (targets.Benchmark, error)
• func NewTarget() targets.ImplementedTarget
• type LoadingOptions
• type Serializer
  • func (s *Serializer) Serialize(p *data.Point, w io.Writer) error

Functions

func NewBenchmark

func NewBenchmark(dbName string, opts *LoadingOptions, dataSourceConfig *source.DataSourceConfig) (targets.Benchmark, error)

func NewTarget

func NewTarget() targets.ImplementedTarget

Types

type LoadingOptions

type LoadingOptions struct {
	Host       string `yaml:"host"`
	User       string
	Pass       string
	Port       string
	ConnDB     string `yaml:"admin-db-name" mapstructure:"admin-db-name"`
	LogBatches bool   `yaml:"log-batches" mapstructure:"log-batches"`

	ProfileFile    string   `yaml:"write-profile" mapstructure:"write-profile"`
	TagColumnTypes []string `yaml:",omitempty" mapstructure:",omitempty"`
}

type Serializer

type Serializer struct{}

Serializer writes a Point in a serialized form for TimescaleDB

func (*Serializer) Serialize

func (s *Serializer) Serialize(p *data.Point, w io.Writer) error

Serialize writes Point p to the given Writer w, so it can be loaded by the TimescaleDB loader. The format is CSV with two lines per Point, with the first row being the tags and the second row being the field values.

e.g., tags,<tag1>,<tag2>,<tag3>,... <measurement>,<timestamp>,<field1>,<field2>,<field3>,...