helpers

package

Go to main page

Versions in this module

v0

v0.8.8

Dec 28, 2014

v0.8.7

Nov 16, 2014

v0.8.6

Nov 16, 2014

Changes in this version

type Server

+ func (self *Server) DataDir() string

+ func (self *Server) RetentionSweepPeriod() time.Duration

+ func (self *Server) SslApiPort() int

v0.8.5

Oct 27, 2014

v0.8.4

Oct 24, 2014

Changes in this version

+ func CreateSeries(prefix string, numOfSeries int) []*influxdb.Series

v0.8.4-rc.1

Oct 21, 2014

v0.8.3

Sep 24, 2014

Changes in this version

type DataTestClient

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

v0.8.2

Sep 5, 2014

Changes in this version

type Server

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

v0.8.1

Sep 3, 2014

v0.8.0

Aug 22, 2014

Changes in this version

+ 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 interface

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

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

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

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

+ WriteJsonData func(series string, c *C, timePrecision ...influxdb.TimePrecision)

+ type DataTestClient struct

+ func (self *DataTestClient) CreateDatabase(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 struct

+ Values []interface{}

+ type Series struct

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

+ type SeriesCollection struct

+ Members []*common.SerializedSeries

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

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

+ type Server struct

+ 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)

v0.8.0-rc.5

Aug 15, 2014

v0.8.0-rc.4

Jul 28, 2014

v0.8.0-rc.3

Jul 21, 2014

v0.8.0-rc.2

Jul 16, 2014

v0.8.0-rc.1

Jul 15, 2014

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL