tsdbtest

Documentation

Index

• Constants
• func CreateTestTSDB(t testing.TB, v3ioConfig *config.V3ioConfig)
• func CreateTestTSDBWithAggregates(t testing.TB, v3ioConfig *config.V3ioConfig, aggregates string)
• func DateStringToMillis(date string) (int64, error)
• func DeleteTSDB(t testing.TB, v3ioConfig *config.V3ioConfig)
• func GetV3ioConfigPath() (string, error)
• func InsertData(t *testing.T, testParams TestParams) *V3ioAdapter
• func LoadV3ioConfig() (*config.V3ioConfig, error)
• func NanosToMillis(nanos int64) int64
• func NormalizePath(path string) string
• func PrefixTablePath(tablePath string) string
• func SetUp(t testing.TB, testParams TestParams) func()
• func SetUpWithDBConfig(t *testing.T, schema *config.Schema, testParams TestParams) func()
• func SetUpWithData(t *testing.T, testOpts TestParams) (*V3ioAdapter, func())
• func ValidateCountOfSamples(t testing.TB, adapter *V3ioAdapter, metricName string, expected int, ...)
• func ValidateRawData(t testing.TB, adapter *V3ioAdapter, metricName string, ...)
• type DataPoint
  • func IteratorToSlice(it chunkenc.Iterator) ([]DataPoint, error)
• type DataPointTimeSorter
  • func (a DataPointTimeSorter) Len() int
  • func (a DataPointTimeSorter) Less(i, j int) bool
  • func (a DataPointTimeSorter) Swap(i, j int)
• type Metric
• type Sample
• type TestOption
• type TestParams
  • func NewTestParams(t testing.TB, opts ...TestOption) TestParams
  • func (tp TestParams) DropTableOnTearDown() bool
  • func (tp TestParams) IgnoreReason() string
  • func (tp TestParams) TimeSeries() TimeSeries
  • func (tp TestParams) V3ioConfig() *config.V3ioConfig
• type TimeSeries

Constants

const DaysInMillis = 24 * HoursInMillis

const HoursInMillis = 60 * MinuteInMillis

const MinuteInMillis = 60 * 1000

const OptDropTableOnTearDown = "DropTableOnTearDown"

const OptIgnoreReason = "IgnoreReason"

const OptTimeSeries = "TimeSeries"

const OptV3ioConfig = "V3ioConfig"

const TsdbDefaultTestConfigPath = "testdata"

Functions

func CreateTestTSDB

func CreateTestTSDB(t testing.TB, v3ioConfig *config.V3ioConfig)

func CreateTestTSDBWithAggregates

func CreateTestTSDBWithAggregates(t testing.TB, v3ioConfig *config.V3ioConfig, aggregates string)

func DateStringToMillis

func DateStringToMillis(date string) (int64, error)

func DeleteTSDB

func DeleteTSDB(t testing.TB, v3ioConfig *config.V3ioConfig)

func GetV3ioConfigPath

func GetV3ioConfigPath() (string, error)

This method will try and load the configuration file from several locations by the following order: 1. Environment variable named 'V3IO_TSDB_CONFIG' 2. Current package's 'testdata/v3io-tsdb-config.yaml' folder 3. $GOPATH/src/github.com/v3io/v3io-tsdb/v3io-tsdb-config.yaml

func InsertData

func InsertData(t *testing.T, testParams TestParams) *V3ioAdapter

func LoadV3ioConfig

func LoadV3ioConfig() (*config.V3ioConfig, error)

func NanosToMillis

func NanosToMillis(nanos int64) int64

func NormalizePath

func NormalizePath(path string) string

func PrefixTablePath

func PrefixTablePath(tablePath string) string

func SetUp

func SetUp(t testing.TB, testParams TestParams) func()

func SetUpWithDBConfig

func SetUpWithDBConfig(t *testing.T, schema *config.Schema, testParams TestParams) func()

func SetUpWithData

func SetUpWithData(t *testing.T, testOpts TestParams) (*V3ioAdapter, func())

func ValidateCountOfSamples

func ValidateCountOfSamples(t testing.TB, adapter *V3ioAdapter, metricName string, expected int, startTimeMs, endTimeMs int64, queryAggStep int64)

func ValidateRawData

func ValidateRawData(t testing.TB, adapter *V3ioAdapter, metricName string, startTimeMs, endTimeMs int64, isValid func(*DataPoint, *DataPoint) bool)

Types

type DataPoint

type DataPoint struct {
	Time  int64
	Value float64
}

func IteratorToSlice

func IteratorToSlice(it chunkenc.Iterator) ([]DataPoint, error)

type DataPointTimeSorter

type DataPointTimeSorter []DataPoint

DataPointTimeSorter sorts DataPoints by time

func (DataPointTimeSorter) Len

func (a DataPointTimeSorter) Len() int

func (DataPointTimeSorter) Less

func (a DataPointTimeSorter) Less(i, j int) bool

func (DataPointTimeSorter) Swap

func (a DataPointTimeSorter) Swap(i, j int)

type Metric

type Metric struct {
	Name   string
	Labels utils.Labels
	Data   []DataPoint
}

type Sample

type Sample struct {
	Lset  utils.Labels
	Time  string
	Value float64
}

type TestOption

type TestOption struct {
	Key   string
	Value interface{}
}

type TestParams

type TestParams map[string]interface{}

func NewTestParams

func NewTestParams(t testing.TB, opts ...TestOption) TestParams

func (TestParams) DropTableOnTearDown

func (tp TestParams) DropTableOnTearDown() bool

func (TestParams) IgnoreReason

func (tp TestParams) IgnoreReason() string

func (TestParams) TimeSeries

func (tp TestParams) TimeSeries() TimeSeries

func (TestParams) V3ioConfig

func (tp TestParams) V3ioConfig() *config.V3ioConfig

type TimeSeries

type TimeSeries []Metric