influx

Documentation

Index

• Constants
• Variables
• type Config
• type Influx
  • func NewInflux(config Config) (*Influx, error)
  • func (flux *Influx) CPUCurrent() (float64, error)
  • func (flux *Influx) CPUFactor() float64
  • func (flux *Influx) CPUHistory(from, to time.Time, step time.Duration) (vector.Vec, error)
  • func (flux *Influx) MemoryCurrent() (float64, error)
  • func (flux *Influx) MemoryFactor() float64
  • func (flux *Influx) MemoryHistory(from, to time.Time, step time.Duration) (vector.Vec, error)
  • func (flux *Influx) Query(cmd string, args ...interface{}) ([]influx.Result, error)
  • func (flux *Influx) SelectFrom(from string, columns ...string) influx.Query
  • func (flux *Influx) SelectFromWithLimit(from string, limit uint, columns ...string) influx.Query
• type Precision
• type SeriesConfig
  • func DefaultSeries() SeriesConfig
  • func MergeSeriesConfigs(configs []SeriesConfig) SeriesConfig
  • func (config SeriesConfig) Merge(another SeriesConfig) SeriesConfig

Constants

const (
	CPU_COEFF = 1e12
)

const (
	MEM_COEFF = 1e12
)

Variables

var (
	ErrEmptyResult            = errors.New("empty result from InfluxDB")
	ErrNoSeriesFound          = errors.New("no series found")
	ErrNoValuesFound          = errors.New("no values found")
	ErrInvalidDataPointFormat = errors.New("invalid data poin format")
)

Types

type Config

type Config struct {
	Database string
	Addr     string
	Username string
	Password string
	NumCPU   uint64
	Memory   uint64
}

type Influx

type Influx struct {
	influx.Client
	// contains filtered or unexported fields
}

func NewInflux

func NewInflux(config Config) (*Influx, error)

func (*Influx) CPUCurrent

func (flux *Influx) CPUCurrent() (float64, error)

func (*Influx) CPUFactor

func (flux *Influx) CPUFactor() float64

func (*Influx) CPUHistory

func (flux *Influx) CPUHistory(from, to time.Time, step time.Duration) (vector.Vec, error)

func (*Influx) MemoryCurrent

func (flux *Influx) MemoryCurrent() (float64, error)

func (*Influx) MemoryFactor

func (flux *Influx) MemoryFactor() float64

func (*Influx) MemoryHistory

func (flux *Influx) MemoryHistory(from, to time.Time, step time.Duration) (vector.Vec, error)

func (*Influx) Query

func (flux *Influx) Query(cmd string, args ...interface{}) ([]influx.Result, error)

func (*Influx) SelectFrom

func (flux *Influx) SelectFrom(from string, columns ...string) influx.Query

func (*Influx) SelectFromWithLimit

func (flux *Influx) SelectFromWithLimit(from string, limit uint, columns ...string) influx.Query

type Precision

type Precision string

const (
	FullPrecision Precision = ""
)

type SeriesConfig

type SeriesConfig struct {
	Step      *time.Duration
	Precision *Precision
}

func DefaultSeries

func DefaultSeries() SeriesConfig

func MergeSeriesConfigs

func MergeSeriesConfigs(configs []SeriesConfig) SeriesConfig

func (SeriesConfig) Merge

func (config SeriesConfig) Merge(another SeriesConfig) SeriesConfig