helpers

package

v0.8.7 Latest Latest Go to latest Published: Nov 16, 2014 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hyperworks/influxdb

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 CreateSeries(prefix string, numOfSeries int) []*influxdb.Series
func ToMap(series common.ApiSeries) []map[string]interface{}
type Client
type DataTestClient
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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 CreateSeries ¶ added in v0.8.4

func CreateSeries(prefix string, numOfSeries int) []*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 ¶ added in v0.8.3

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) DataDir ¶ added in v0.8.6

func (self *Server) DataDir() string

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) RetentionSweepPeriod ¶ added in v0.8.6

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

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) SslApiPort ¶ added in v0.8.6

func (self *Server) SslApiPort() int

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 ¶ added in v0.8.2

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

Source Files ¶

View all Source files

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