Versions in this module Expand all Collapse all v0 v0.3.0 Oct 11, 2023 Changes in this version + type InfluxQueryService interface + ExecuteQuery func(client influx.Client, database, command string) ([]influx.Result, error) + ExecuteShowQuery func(influxClient influx.Client, database, query string) (*InfluxShowResult, error) + func NewInfluxQueryService() InfluxQueryService + type InfluxShowResult struct + Values [][]string + type MockClient struct + 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
Go to main page