influxdb

Documentation

Index

• Constants
• Variables
• type Config
  • func NewDefaultConfig() Config
  • func (c *Config) Validate() error
• type Database
• type InfluxDBEntity
• type InfluxDBRepository
  • func New(influxCfg *Config) *InfluxDBRepository
  • func (influxDBRepository *InfluxDBRepository) AddTimeCondition(whereStr *string, operator string, value int64)
  • func (influxDBRepository *InfluxDBRepository) AddWhereCondition(whereStr *string, key string, operator string, value string)
  • func (influxDBRepository *InfluxDBRepository) AddWhereConditionDirect(whereStr *string, condition string)
  • func (influxDBRepository *InfluxDBRepository) CreateDatabase(db string) error
  • func (influxDBRepository *InfluxDBRepository) ModifyDefaultRetentionPolicy(db string) error
  • func (influxDBRepository *InfluxDBRepository) QueryDB(cmd, database string) (res []client.Result, err error)
  • func (influxDBRepository *InfluxDBRepository) WritePoints(points []*client.Point, bpCfg client.BatchPointsConfig) error
• type InfluxDBRow
  • func NormalizeResult(rows []*InfluxDBRow) []*InfluxDBRow
  • func PackMap(results []client.Result) []*InfluxDBRow
• type Measurement
• type Order
• type QueryCondition
• type Statement
  • func (s *Statement) AppendTimeConditionIntoWhereClause(queryCondition QueryCondition)
  • func (s Statement) BuildQueryCmd() string
  • func (s *Statement) SetLimitClauseFromQueryCondition(queryCondition QueryCondition)
  • func (s *Statement) SetOrderClauseFromQueryCondition(queryCondition QueryCondition)

Constants

const (
	// Time is InfluxDB time tag
	Time string = "time"

	// EndTime is InfluxDB time tag
	EndTime string = "end_time"

	// ClusterStatus is cluster_status database
	ClusterStatus Database = "alameda_cluster_status"
	// Prediction is prediction database
	Prediction Database = "alameda_prediction"
	// Recommendation is recommendation database
	Recommendation Database = "alameda_recommendation"
	// Score is score database
	Score Database = "alameda_score"
)

Variables

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

Types

type Config

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

func NewDefaultConfig

func NewDefaultConfig() Config

func (*Config) Validate

func (c *Config) Validate() error

type Database

type Database string

type InfluxDBEntity

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

type InfluxDBRepository

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

InfluxDBRepository interacts with database

func New

func New(influxCfg *Config) *InfluxDBRepository

New returns InfluxDBRepository instance

func (*InfluxDBRepository) AddTimeCondition

func (influxDBRepository *InfluxDBRepository) AddTimeCondition(whereStr *string, operator string, value int64)

func (*InfluxDBRepository) AddWhereCondition

func (influxDBRepository *InfluxDBRepository) AddWhereCondition(whereStr *string, key string, operator string, value string)

func (*InfluxDBRepository) AddWhereConditionDirect

func (influxDBRepository *InfluxDBRepository) AddWhereConditionDirect(whereStr *string, condition string)

func (*InfluxDBRepository) CreateDatabase

func (influxDBRepository *InfluxDBRepository) CreateDatabase(db string) error

CreateDatabase creates database

func (*InfluxDBRepository) ModifyDefaultRetentionPolicy

func (influxDBRepository *InfluxDBRepository) ModifyDefaultRetentionPolicy(db string) error

Modify default retention policy

func (*InfluxDBRepository) QueryDB

func (influxDBRepository *InfluxDBRepository) QueryDB(cmd, database string) (res []client.Result, err error)

QueryDB queries database

func (*InfluxDBRepository) WritePoints

func (influxDBRepository *InfluxDBRepository) WritePoints(points []*client.Point, bpCfg client.BatchPointsConfig) error

WritePoints writes points to database

type InfluxDBRow

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

func NormalizeResult

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

func PackMap

func PackMap(results []client.Result) []*InfluxDBRow

type Measurement

type Measurement string

type Order

type Order = int

Order Order enumerator

const (
	// Asc Represent ascending order
	Asc Order = 0
	// Desc Represent descending order
	Desc Order = 1
)

type QueryCondition

type QueryCondition struct {
	StartTime      *time.Time
	EndTime        *time.Time
	StepTime       *time.Duration
	TimestampOrder Order
	Limit          int
}

QueryCondition Others query condition

type Statement

type Statement struct {
	Measurement    Measurement
	SelectedFields []string
	GroupByTags    []string
	WhereClause    string
	OrderClause    string
	LimitClause    string
}

func (*Statement) AppendTimeConditionIntoWhereClause

func (s *Statement) AppendTimeConditionIntoWhereClause(queryCondition QueryCondition)

func (Statement) BuildQueryCmd

func (s Statement) BuildQueryCmd() string

func (*Statement) SetLimitClauseFromQueryCondition

func (s *Statement) SetLimitClauseFromQueryCondition(queryCondition QueryCondition)

func (*Statement) SetOrderClauseFromQueryCondition

func (s *Statement) SetOrderClauseFromQueryCondition(queryCondition QueryCondition)