test

Documentation

Index

• func DestroyMySQL(t *testing.T)
• func InitMySQL(t *testing.T) *store.MySQL
• func ParseSQLFile(t *testing.T) map[string]string
• type MockChannelReceiverProvider
  • func (provider MockChannelReceiverProvider) GetChannelReceiver(channel string, names []string) map[string]string
• type MockDatasource
  • func (mock MockDatasource) CheckQuery(now time.Time, query string) error
  • func (mock MockDatasource) Close() error
  • func (mock MockDatasource) Query(now time.Time, query string) ([]datasource.Point, error)
• type MockInfluxdbClient
  • func (client *MockInfluxdbClient) Close() error
  • func (client *MockInfluxdbClient) Ping(t time.Duration) (time.Duration, string, error)
  • func (client *MockInfluxdbClient) Query(q influxdb.Query) (*influxdb.Response, error)
  • func (client *MockInfluxdbClient) QueryAsChunk(q influxdb.Query) (*influxdb.ChunkedResponse, error)
  • func (client *MockInfluxdbClient) Write(bp influxdb.BatchPoints) error

Functions

func DestroyMySQL

func DestroyMySQL(t *testing.T)

func InitMySQL

func InitMySQL(t *testing.T) *store.MySQL

func ParseSQLFile

func ParseSQLFile(t *testing.T) map[string]string

Types

type MockChannelReceiverProvider

type MockChannelReceiverProvider struct{}

func (MockChannelReceiverProvider) GetChannelReceiver

func (provider MockChannelReceiverProvider) GetChannelReceiver(channel string, names []string) map[string]string

type MockDatasource

type MockDatasource struct{}

func (MockDatasource) CheckQuery

func (mock MockDatasource) CheckQuery(now time.Time, query string) error

func (MockDatasource) Close

func (mock MockDatasource) Close() error

func (MockDatasource) Query

func (mock MockDatasource) Query(now time.Time, query string) ([]datasource.Point, error)

type MockInfluxdbClient

type MockInfluxdbClient struct{}

func (*MockInfluxdbClient) Close

func (client *MockInfluxdbClient) Close() error

func (*MockInfluxdbClient) Ping

func (client *MockInfluxdbClient) Ping(t time.Duration) (time.Duration, string, error)

func (*MockInfluxdbClient) Query

func (client *MockInfluxdbClient) Query(q influxdb.Query) (*influxdb.Response, error)

func (*MockInfluxdbClient) QueryAsChunk

func (client *MockInfluxdbClient) QueryAsChunk(q influxdb.Query) (*influxdb.ChunkedResponse, error)

func (*MockInfluxdbClient) Write

func (client *MockInfluxdbClient) Write(bp influxdb.BatchPoints) error