helpers

Documentation

Index

• func CreatePoints(name string, numOfColumns, numOfPoints int) []*influxdb.Series
• func CreatePointsFromFunc(name string, numOfColumns, numOfPoints int, f func(int) float64) []*influxdb.Series
• func ToMap(series common.ApiSeries) []map[string]interface{}
• type Client
• type DataTestClient
  • func (self *DataTestClient) CreateDatabase(db string, c *C)
  • func (self *DataTestClient) DeleteDatabase(db string, c *C)
  • func (self *DataTestClient) RunInvalidQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
  • func (self *DataTestClient) RunQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
  • func (self *DataTestClient) RunQueryWithNumbers(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
  • func (self *DataTestClient) SetDB(db string)
  • func (self *DataTestClient) WriteData(series []*influxdb.Series, c *C, timePrecision ...influxdb.TimePrecision)
  • func (self *DataTestClient) WriteJsonData(seriesString string, c *C, timePrecision ...influxdb.TimePrecision)
• type Point
• type Series
  • func (self *Series) GetValueForPointAndColumn(pointIndex int, columnName string, c *C) interface{}
• type SeriesCollection
  • func ResultsToSeriesCollection(results []*common.SerializedSeries) *SeriesCollection
  • func (self *SeriesCollection) GetSeries(name string, c *C) *Series
• type Server
  • func NewServer(configFile string, c *C) *Server
  • func NewServerWithArgs(configFile string, c *C, args ...string) *Server
  • func NewSslServer(configFile string, c *C) *Server
  • func (self *Server) ApiPort() int
  • func (self *Server) AssertContinuousQueryCount(db string, count int, c *C)
  • func (self *Server) Delete(url, body string, c *C) *http.Response
  • func (self *Server) DoesWalExist() error
  • func (self *Server) Get(url string, c *C) []byte
  • func (self *Server) GetClient(db string, c *C) *influxdb.Client
  • func (self *Server) GetClientWithUser(db, username, password string, c *C) *influxdb.Client
  • func (self *Server) GetErrorBody(database, query, username, password string, onlyLocal bool, c *C) (string, int)
  • func (self *Server) GetResponse(database, query, username, password string, onlyLocal bool, c *C) *http.Response
  • func (self *Server) Post(url, data string, c *C) *http.Response
  • func (self *Server) PostGetBody(url, data string, c *C) []byte
  • func (self *Server) Query(database, query string, onlyLocal bool, c *C) *SeriesCollection
  • func (self *Server) QueryAsRoot(database, query string, onlyLocal bool, c *C) *SeriesCollection
  • func (self *Server) QueryWithUsername(database, query string, onlyLocal bool, c *C, username, password string) *SeriesCollection
  • func (self *Server) RemoveAllContinuousQueries(db string, c *C)
  • func (self *Server) Request(method, url, data string, c *C) *http.Response
  • func (self *Server) RunQuery(query string, precision influxdb.TimePrecision, c *C) []*influxdb.Series
  • func (self *Server) RunQueryAsRoot(query string, precision influxdb.TimePrecision, c *C) []*influxdb.Series
  • func (self *Server) RunQueryAsUser(query string, precision influxdb.TimePrecision, username, password string, ...) []*influxdb.Series
  • func (self *Server) SetSslOnly(sslOnly bool)
  • func (self *Server) Start() error
  • func (self *Server) Stop()
  • func (self *Server) VerifyForbiddenQuery(database, query string, onlyLocal bool, c *C, username, password string) string
  • func (self *Server) WaitForServerToStart()
  • func (self *Server) WaitForServerToSync()
  • func (self *Server) WriteData(data interface{}, c *C, precision ...influxdb.TimePrecision)
  • func (self *Server) WriteDataToDatabase(db string, data interface{}, c *C, precision ...influxdb.TimePrecision)

Functions

func CreatePoints

func CreatePoints(name string, numOfColumns, numOfPoints int) []*influxdb.Series

func CreatePointsFromFunc

func CreatePointsFromFunc(name string, numOfColumns, numOfPoints int, f func(int) float64) []*influxdb.Series

func ToMap

func ToMap(series common.ApiSeries) []map[string]interface{}

Types

type Client

type Client interface {
	RunQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
	RunQueryWithNumbers(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
	RunInvalidQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series
	WriteData(series []*influxdb.Series, c *C, timePrecision ...influxdb.TimePrecision)
	WriteJsonData(series string, c *C, timePrecision ...influxdb.TimePrecision)
}

type DataTestClient

type DataTestClient struct {
	// contains filtered or unexported fields
}

func (*DataTestClient) CreateDatabase

func (self *DataTestClient) CreateDatabase(db string, c *C)

func (*DataTestClient) DeleteDatabase

func (self *DataTestClient) DeleteDatabase(db string, c *C)

func (*DataTestClient) RunInvalidQuery

func (self *DataTestClient) RunInvalidQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series

func (*DataTestClient) RunQuery

func (self *DataTestClient) RunQuery(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series

func (*DataTestClient) RunQueryWithNumbers

func (self *DataTestClient) RunQueryWithNumbers(query string, c *C, timePrecision ...influxdb.TimePrecision) []*influxdb.Series

func (*DataTestClient) SetDB

func (self *DataTestClient) SetDB(db string)

func (*DataTestClient) WriteData

func (self *DataTestClient) WriteData(series []*influxdb.Series, c *C, timePrecision ...influxdb.TimePrecision)

func (*DataTestClient) WriteJsonData

func (self *DataTestClient) WriteJsonData(seriesString string, c *C, timePrecision ...influxdb.TimePrecision)

type Point

type Point struct {
	Values []interface{}
}

type Series

type Series struct {
	*common.SerializedSeries
}

func (*Series) GetValueForPointAndColumn

func (self *Series) GetValueForPointAndColumn(pointIndex int, columnName string, c *C) interface{}

type SeriesCollection

type SeriesCollection struct {
	Members []*common.SerializedSeries
}

func ResultsToSeriesCollection

func ResultsToSeriesCollection(results []*common.SerializedSeries) *SeriesCollection

func (*SeriesCollection) GetSeries

func (self *SeriesCollection) GetSeries(name string, c *C) *Series

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(configFile string, c *C) *Server

func NewServerWithArgs

func NewServerWithArgs(configFile string, c *C, args ...string) *Server

func NewSslServer

func NewSslServer(configFile string, c *C) *Server

func (*Server) ApiPort

func (self *Server) ApiPort() int

func (*Server) AssertContinuousQueryCount

func (self *Server) AssertContinuousQueryCount(db string, count int, c *C)

func (*Server) Delete

func (self *Server) Delete(url, body string, c *C) *http.Response

func (*Server) DoesWalExist

func (self *Server) DoesWalExist() error

func (*Server) Get

func (self *Server) Get(url string, c *C) []byte

func (*Server) GetClient

func (self *Server) GetClient(db string, c *C) *influxdb.Client

optional db

func (*Server) GetClientWithUser

func (self *Server) GetClientWithUser(db, username, password string, c *C) *influxdb.Client

func (*Server) GetErrorBody

func (self *Server) GetErrorBody(database, query, username, password string, onlyLocal bool, c *C) (string, int)

func (*Server) GetResponse

func (self *Server) GetResponse(database, query, username, password string, onlyLocal bool, c *C) *http.Response

func (*Server) Post

func (self *Server) Post(url, data string, c *C) *http.Response

func (*Server) PostGetBody

func (self *Server) PostGetBody(url, data string, c *C) []byte

func (*Server) Query

func (self *Server) Query(database, query string, onlyLocal bool, c *C) *SeriesCollection

func (*Server) QueryAsRoot

func (self *Server) QueryAsRoot(database, query string, onlyLocal bool, c *C) *SeriesCollection

func (*Server) QueryWithUsername

func (self *Server) QueryWithUsername(database, query string, onlyLocal bool, c *C, username, password string) *SeriesCollection

func (*Server) RemoveAllContinuousQueries

func (self *Server) RemoveAllContinuousQueries(db string, c *C)

func (*Server) Request

func (self *Server) Request(method, url, data string, c *C) *http.Response

func (*Server) RunQuery

func (self *Server) RunQuery(query string, precision influxdb.TimePrecision, c *C) []*influxdb.Series

func (*Server) RunQueryAsRoot

func (self *Server) RunQueryAsRoot(query string, precision influxdb.TimePrecision, c *C) []*influxdb.Series

func (*Server) RunQueryAsUser

func (self *Server) RunQueryAsUser(query string, precision influxdb.TimePrecision, username, password string, isValid bool, c *C) []*influxdb.Series

func (*Server) SetSslOnly

func (self *Server) SetSslOnly(sslOnly bool)

func (*Server) Start

func (self *Server) Start() error

func (*Server) Stop

func (self *Server) Stop()

func (*Server) VerifyForbiddenQuery

func (self *Server) VerifyForbiddenQuery(database, query string, onlyLocal bool, c *C, username, password string) string

func (*Server) WaitForServerToStart

func (self *Server) WaitForServerToStart()

func (*Server) WaitForServerToSync

func (self *Server) WaitForServerToSync()

func (*Server) WriteData

func (self *Server) WriteData(data interface{}, c *C, precision ...influxdb.TimePrecision)

func (*Server) WriteDataToDatabase

func (self *Server) WriteDataToDatabase(db string, data interface{}, c *C, precision ...influxdb.TimePrecision)