influxqueries

Documentation

Index

• type InfluxQueryService
  • func NewInfluxQueryService() InfluxQueryService
• type InfluxShowResult
• type MockClient
  • func (mc *MockClient) Close() error
  • func (mc *MockClient) Ping(timeout time.Duration) (time.Duration, string, error)
  • func (mc *MockClient) Query(q influx.Query) (*influx.Response, error)
  • func (mc *MockClient) QueryAsChunk(q influx.Query) (*influx.ChunkedResponse, error)
  • func (mc *MockClient) Write(bp influx.BatchPoints) error

Types

type InfluxQueryService

type InfluxQueryService interface {
	ExecuteQuery(client influx.Client, database, command string) ([]influx.Result, error)
	ExecuteShowQuery(influxClient influx.Client, database, query string) (*InfluxShowResult, error)
}

InfluxQueryService contains helper functions to work with the InfluxDB client

func NewInfluxQueryService

func NewInfluxQueryService() InfluxQueryService

NewInfluxQueryService creates a new implementation of the client utils struct

type InfluxShowResult

type InfluxShowResult struct {
	Values [][]string
}

InfluxShowResult contains the results/values from an 'SHOW ' query

type MockClient

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

MockClient mocks an InfluxDB client

func (*MockClient) Close

func (mc *MockClient) Close() error

Close mock

func (*MockClient) Ping

func (mc *MockClient) Ping(timeout time.Duration) (time.Duration, string, error)

Ping mock

func (*MockClient) Query

func (mc *MockClient) Query(q influx.Query) (*influx.Response, error)

Query mock

func (*MockClient) QueryAsChunk

func (mc *MockClient) QueryAsChunk(q influx.Query) (*influx.ChunkedResponse, error)

QueryAsChunk mock

func (*MockClient) Write

func (mc *MockClient) Write(bp influx.BatchPoints) error

Write mock