influxdb

Documentation

Index

• Variables
• func CompareRawdataWithInfluxResults(readRawdata *Common.ReadRawdata, results []Client.Result) error
• func InfluxResultToReadRawdata(results []Client.Result, query *Common.Query) *Common.ReadRawdata
• func ReadRawdata(config *Config, queries []*Common.Query) ([]*Common.ReadRawdata, error)
• func WriteRawdata(config *Config, writeRawdata []*Common.WriteRawdata) error
• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) Validate() error
• type Database
• type Field
• type Function
• type FunctionType
• type InfluxClient
  • func NewClient(influxCfg *Config) *InfluxClient
  • func (p *InfluxClient) CreateDatabase(db string) error
  • func (p *InfluxClient) DeleteDatabase(db string) error
  • func (p *InfluxClient) DeleteMeasurement(db, measurement string) error
  • func (p *InfluxClient) ModifyDefaultRetentionPolicy(db string) error
  • func (p *InfluxClient) Ping() error
  • func (p *InfluxClient) QueryDB(cmd, database string) (res []Client.Result, err error)
  • func (p *InfluxClient) WritePoints(points []*Client.Point, bpCfg Client.BatchPointsConfig) error
• type InfluxEntity
• type InfluxRow
  • func NormalizeResult(rows []*InfluxRow) []*InfluxRow
  • func PackMap(results []Client.Result) []*InfluxRow
  • func ReadRawdataToInfluxDBRow(readRawdata *Common.ReadRawdata) []*InfluxRow
• type Measurement
• type Statement
  • func NewStatement(query *Common.Query) *Statement
  • func (s *Statement) AppendWhereClause(key string, operator string, value string)
  • func (s *Statement) AppendWhereClauseByList(key string, operator string, listOperator string, values []string)
  • func (s *Statement) AppendWhereClauseDirectly(condition string)
  • func (s *Statement) AppendWhereClauseFromTimeCondition()
  • func (s *Statement) AppendWhereClauseWithTime(operator string, value int64)
  • func (s *Statement) BuildQueryCmd() string
  • func (s *Statement) Clear()
  • func (s *Statement) SetFunction(funcType FunctionType, funcName, target string)
  • func (s *Statement) SetLimitClauseFromQueryCondition()
  • func (s *Statement) SetOrderClauseFromQueryCondition()
• type Tag

Variables

var (

	// ZeroTime is used as a constant of timestamp
	ZeroTime = time.Unix(0, 0)
)

Functions

func CompareRawdataWithInfluxResults

func CompareRawdataWithInfluxResults(readRawdata *Common.ReadRawdata, results []Client.Result) error

func InfluxResultToReadRawdata

func InfluxResultToReadRawdata(results []Client.Result, query *Common.Query) *Common.ReadRawdata

func ReadRawdata

func ReadRawdata(config *Config, queries []*Common.Query) ([]*Common.ReadRawdata, error)

func WriteRawdata

func WriteRawdata(config *Config, writeRawdata []*Common.WriteRawdata) error

Types

type Config

type Config struct {
	Address                string `mapstructure:"address"`
	Username               string `mapstructure:"username"`
	Password               string `mapstructure:"password"`
	InsecureSkipVerify     bool   `mapstructure:"insecureSkipVerify"`
	RetentionDuration      string `mapstructure:"retentionDuration"`
	RetentionShardDuration string `mapstructure:"retentionShardDuration"`
}

Configuration of InfluxDB data source

func NewDefaultConfig

func NewDefaultConfig() *Config

Provide default configuration for InfluxDB

func (*Config) Validate

func (c *Config) Validate() error

Confirm the InfluxDB configuration is validated

type Database

type Database string

type Field

type Field string

type Function

type Function struct {
	FuncType FunctionType
	FuncName string
	Target   string
}

type FunctionType

type FunctionType int

const (
	NoneFunction FunctionType = iota
	Aggregate
	Select
)

type InfluxClient

type InfluxClient struct {
	Address                string
	Username               string
	Password               string
	RetentionDuration      string
	RetentionShardDuration string
}

InfluxDB client interacts with database

func NewClient

func NewClient(influxCfg *Config) *InfluxClient

Instance InfluxDB API client with configuration

func (*InfluxClient) CreateDatabase

func (p *InfluxClient) CreateDatabase(db string) error

Create database

func (*InfluxClient) DeleteDatabase

func (p *InfluxClient) DeleteDatabase(db string) error

Delete database

func (*InfluxClient) DeleteMeasurement

func (p *InfluxClient) DeleteMeasurement(db, measurement string) error

Delete measurement

func (*InfluxClient) ModifyDefaultRetentionPolicy

func (p *InfluxClient) ModifyDefaultRetentionPolicy(db string) error

Modify default retention policy

func (*InfluxClient) Ping

func (p *InfluxClient) Ping() error

func (*InfluxClient) QueryDB

func (p *InfluxClient) QueryDB(cmd, database string) (res []Client.Result, err error)

Query database

func (*InfluxClient) WritePoints

func (p *InfluxClient) WritePoints(points []*Client.Point, bpCfg Client.BatchPointsConfig) error

Write points to database

type InfluxEntity

type InfluxEntity struct {
	Time   time.Time
	Tags   map[string]string
	Fields map[string]interface{}
}

type InfluxRow

type InfluxRow struct {
	Name    string
	Tags    map[string]string
	Data    []map[string]string
	Partial bool
}

func NormalizeResult

func NormalizeResult(rows []*InfluxRow) []*InfluxRow

func PackMap

func PackMap(results []Client.Result) []*InfluxRow

func ReadRawdataToInfluxDBRow

func ReadRawdataToInfluxDBRow(readRawdata *Common.ReadRawdata) []*InfluxRow

type Measurement

type Measurement string

type Statement

type Statement struct {
	QueryCondition *DBCommon.QueryCondition
	Database       Database
	Measurement    Measurement
	SelectedFields []string
	GroupByTags    []string
	Function       *Function
	WhereClause    string
	OrderClause    string
	LimitClause    string
}

func NewStatement

func NewStatement(query *Common.Query) *Statement

func (*Statement) AppendWhereClause

func (s *Statement) AppendWhereClause(key string, operator string, value string)

func (*Statement) AppendWhereClauseByList

func (s *Statement) AppendWhereClauseByList(key string, operator string, listOperator string, values []string)

func (*Statement) AppendWhereClauseDirectly

func (s *Statement) AppendWhereClauseDirectly(condition string)

func (*Statement) AppendWhereClauseFromTimeCondition

func (s *Statement) AppendWhereClauseFromTimeCondition()

func (*Statement) AppendWhereClauseWithTime

func (s *Statement) AppendWhereClauseWithTime(operator string, value int64)

func (*Statement) BuildQueryCmd

func (s *Statement) BuildQueryCmd() string

func (*Statement) Clear

func (s *Statement) Clear()

func (*Statement) SetFunction

func (s *Statement) SetFunction(funcType FunctionType, funcName, target string)

func (*Statement) SetLimitClauseFromQueryCondition

func (s *Statement) SetLimitClauseFromQueryCondition()

func (*Statement) SetOrderClauseFromQueryCondition

func (s *Statement) SetOrderClauseFromQueryCondition()

type Tag

type Tag string