Versions in this module Expand all Collapse all v0 v0.1.1 Nov 11, 2022 v0.1.0 Nov 11, 2022 Changes in this version + const TimeValueIdx + const ValueTimeIdx + func MustBegin(db *sql.DB) *sql.Tx + func MustConnect(dbType, connStr string) *sql.DB + func MustExec(db *sql.DB, query string, args ...interface{}) sql.Result + func MustQuery(db *sql.DB, query string, args ...interface{}) *sql.Rows + func NewBenchmark(dbName string, opts *LoadingOptions, dataSourceConfig *source.DataSourceConfig) (targets.Benchmark, error) + func NewTarget() targets.ImplementedTarget + type LoadingOptions struct + ChunkTime time.Duration + ConnDB string + CreateMetricsTable bool + FieldIndex string + FieldIndexCount int + ForceTextFormat bool + Host string + InTableTag bool + LogBatches bool + NumberPartitions int + PartitionColumn string + PartitionIndex bool + Pass string + Port string + PostgresConnect string + ProfileFile string + ReplicationFactor int + ReplicationStatsFile string + TagColumnTypes []string + TimeIndex bool + TimePartitionIndex bool + UseHypertable bool + UseInsert bool + UseJSON bool + User string + func (o *LoadingOptions) GetConnectString(dbName string) string + type Serializer struct + func (s *Serializer) Serialize(p *data.Point, w io.Writer) error