database

Nov 18, 2020

Changes in this version

+ type InfluxdbAdapter struct

+ func NewInfluxdbAdapter(config influxdb.HTTPConfig) (*InfluxdbAdapter, error)

+ func (a *InfluxdbAdapter) ExtractTagFromQuery(query, database, tagKey string) ([]string, error)

+ func (a *InfluxdbAdapter) FindMeasurements(database string) ([]string, error)

+ func (a *InfluxdbAdapter) FindMeasurementsLike(database string, regex string) ([]string, error)

+ func (a *InfluxdbAdapter) QueryAndIterate(query, database string, fn IterateQueryFunc) error

+ func (a *InfluxdbAdapter) WritePoints(database string, points ...*influxdb.Point) error

+ type IterateQueryFunc func(int, int, models.Row) error

Nov 3, 2020

Changes in this version

+ type DatabaseAdapter struct

+ func NewDatabaseAdapter(server, user, password string, port int, database string, minConn, maxConn int, ...) (*DatabaseAdapter, error)

+ func (a *DatabaseAdapter) FindDatabases() ([]string, error)