database

Documentation

Index

• type DatabaseAdapter
  • func NewDatabaseAdapter(server, user, password string, port int, database string, minConn, maxConn int, ...) (*DatabaseAdapter, error)
  • func (a *DatabaseAdapter) FindDatabases() ([]string, error)
• type InfluxdbAdapter
  • 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

Types

type DatabaseAdapter

type DatabaseAdapter struct {
	*gorm.DB
}

func NewDatabaseAdapter

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

func (*DatabaseAdapter) FindDatabases

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

type InfluxdbAdapter

type InfluxdbAdapter struct {
	influxdb.Client
}

func NewInfluxdbAdapter

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

func (*InfluxdbAdapter) ExtractTagFromQuery

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

func (*InfluxdbAdapter) FindMeasurements

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

func (*InfluxdbAdapter) FindMeasurementsLike

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

func (*InfluxdbAdapter) QueryAndIterate

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

func (*InfluxdbAdapter) WritePoints

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

type IterateQueryFunc

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