tests

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 27, 2025 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

This package is a set of convenience helpers and structs to make integration testing easier

Index

Constants

This section is empty.

Variables

View Source 
var FailCount int
View Source 
var LosAngeles = mustParseLocation("America/Los_Angeles")
View Source 
var SuccessCount int

Functions

func AppendQueries added in v1.3.0 

func AppendQueries(queries *[]*Query, line int, expr string, startTime time.Time, exps []*PromExp, mod string) error

func CompareSortedResults added in v1.5.0 

func CompareSortedResults(expString, actString string) bool

func GenTimeSeries added in v1.4.0 

func GenTimeSeries(metric labels.Labels, vals []parser.SequenceValue, gap model.Duration) *prompb.TimeSeries

func MustReadAll 

func MustReadAll(r io.Reader) []byte

MustReadAll reads r. Panic on error.

func NewPromTestFromFile added in v1.3.0 

func NewPromTestFromFile(t *testing.T, filename string, db string, rp string, s Server) (float64, error)

func NewRetentionPolicy added in v1.4.0 

func NewRetentionPolicy(name string, rf int, shardDuration, duration time.Duration) *meta.RetentionPolicySpec

func NewRetentionPolicySpec 

func NewRetentionPolicySpec(name string, rf int, duration time.Duration) *meta.RetentionPolicySpec

form a correct retention policy given name, replication factor and duration

func RemoteEnabled 

func RemoteEnabled() bool

Types

type Config 

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

Config is a test wrapper around a run.Config. It also contains a root temp directory, making cleanup easier.

func NewConfig 

func NewConfig() *Config

NewConfig returns the default config with temporary paths.

func NewParseConfig 

func NewParseConfig(path string) *Config

NewConfig returns the default config with temporary paths.

func ParseConfig 

func ParseConfig(path string) *Config

func (*Config) FromTomlFile 

func (c *Config) FromTomlFile(fpath string) error

FromTomlFile loads the config from a TOML file.

type LocalServer 

type LocalServer struct {
	*tssql.Server

	Config *Config
	// contains filtered or unexported fields
}

LocalServer is a Server that is running in-process and can be accessed directly

func (*LocalServer) CheckDropDatabases 

func (s *LocalServer) CheckDropDatabases(dbs []string) error

func (*LocalServer) Close 

func (s *LocalServer) Close()

Close shuts down the server and removes all temporary paths.

func (*LocalServer) Closed 

func (s *LocalServer) Closed() bool

func (*LocalServer) ContainDatabase 

func (s *LocalServer) ContainDatabase(name string) bool

func (*LocalServer) CreateDatabase 

func (s *LocalServer) CreateDatabase(db string) (*meta.DatabaseInfo, error)

func (*LocalServer) CreateDatabaseAndRetentionPolicy 

func (s *LocalServer) CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error

CreateDatabaseAndRetentionPolicy will create the database and retention policy.

func (*LocalServer) CreateDatabaseShardKey 

func (s *LocalServer) CreateDatabaseShardKey(db string, shardKey string) error

func (*LocalServer) CreateDatabaseTagArrayEnabledAndRp added in v1.1.0 

func (s *LocalServer) CreateDatabaseTagArrayEnabledAndRp(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error

func (*LocalServer) CreateMeasurement added in v1.1.1 

func (s *LocalServer) CreateMeasurement(mst string) error

func (*LocalServer) DropDatabase 

func (s *LocalServer) DropDatabase(db string) error

func (LocalServer) HTTPGet 

func (s LocalServer) HTTPGet(url string) (results string, err error)

HTTPGet makes an HTTP GET request to the server and returns the response.

func (LocalServer) HTTPPost 

func (s LocalServer) HTTPPost(url string, content []byte) (results string, err error)

HTTPPost makes an HTTP POST request to the server and returns the response.

func (LocalServer) MustQuery 

func (s LocalServer) MustQuery(query string) string

MustQuery executes a query against the server and returns the results.

func (LocalServer) MustQueryWithParams 

func (s LocalServer) MustQueryWithParams(query string, values url.Values) string

MustQueryWithParams executes a query against the server and returns the results.

func (LocalServer) MustWrite 

func (s LocalServer) MustWrite(db, rp, body string, params url.Values) string

MustWrite executes a write to the server. Panic on error.

func (*LocalServer) Open 

func (s *LocalServer) Open() error

Open opens the server. If running this test on a 32-bit platform it reduces the size of series files so that they can all be addressable in the process.

func (LocalServer) Query 

func (s LocalServer) Query(query string) (results string, err error)

Query executes a query against the server and returns the results.

func (LocalServer) QueryPromWithParams added in v1.3.0 

func (s LocalServer) QueryPromWithParams(query string, values url.Values, path string) (string, error)

func (LocalServer) QueryWithParams 

func (s LocalServer) QueryWithParams(query string, values url.Values) (results string, err error)

Query executes a query against the server and returns the results.

func (*LocalServer) Reset 

func (s *LocalServer) Reset() error

func (*LocalServer) SetLogOutput 

func (s *LocalServer) SetLogOutput(w io.Writer)

func (LocalServer) URL 

func (c LocalServer) URL() string

func (LocalServer) Write 

func (s LocalServer) Write(db, rp, body string, params url.Values) (results string, err error)

Write executes a write against the server and returns the results.

type PromExp added in v1.3.0 

type PromExp struct {
	Value  parser.SequenceValue
	Metric labels.Labels
}

type PromTest added in v1.3.0 

type PromTest struct {
	Test
	// contains filtered or unexported fields
}

PromTest is a sequence of read and write commands that are run against a test storage.

type Query 

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

func (*Query) Error 

func (q *Query) Error(err error) string

func (*Query) Execute 

func (q *Query) Execute(s Server) (err error)

Execute runs the command and returns an err if it fails

func (*Query) ExecuteProm added in v1.3.0 

func (q *Query) ExecuteProm(s Server) (err error)

func (*Query) ExecuteResult 

func (q *Query) ExecuteResult(s Server) (result string, err error)

type RemoteServer 

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

RemoteServer is a Server that is accessed remotely via the HTTP API

func (*RemoteServer) CheckDropDatabases 

func (s *RemoteServer) CheckDropDatabases(dbs []string) error

func (*RemoteServer) Close 

func (s *RemoteServer) Close()

func (*RemoteServer) Closed 

func (s *RemoteServer) Closed() bool

func (*RemoteServer) ContainDatabase 

func (s *RemoteServer) ContainDatabase(name string) bool

func (*RemoteServer) CreateDatabase 

func (s *RemoteServer) CreateDatabase(db string) (*meta.DatabaseInfo, error)

func (*RemoteServer) CreateDatabaseAndRetentionPolicy 

func (s *RemoteServer) CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error

func (*RemoteServer) CreateDatabaseShardKey 

func (s *RemoteServer) CreateDatabaseShardKey(db string, shardKey string) error

func (*RemoteServer) CreateDatabaseTagArrayEnabledAndRp added in v1.1.0 

func (s *RemoteServer) CreateDatabaseTagArrayEnabledAndRp(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error

func (*RemoteServer) CreateMeasurement added in v1.1.1 

func (s *RemoteServer) CreateMeasurement(mst string) error

func (*RemoteServer) DropDatabase 

func (s *RemoteServer) DropDatabase(db string) error

func (RemoteServer) HTTPGet 

func (s RemoteServer) HTTPGet(url string) (results string, err error)

HTTPGet makes an HTTP GET request to the server and returns the response.

func (RemoteServer) HTTPPost 

func (s RemoteServer) HTTPPost(url string, content []byte) (results string, err error)

HTTPPost makes an HTTP POST request to the server and returns the response.

func (RemoteServer) MustQuery 

func (s RemoteServer) MustQuery(query string) string

MustQuery executes a query against the server and returns the results.

func (RemoteServer) MustQueryWithParams 

func (s RemoteServer) MustQueryWithParams(query string, values url.Values) string

MustQueryWithParams executes a query against the server and returns the results.

func (RemoteServer) MustWrite 

func (s RemoteServer) MustWrite(db, rp, body string, params url.Values) string

MustWrite executes a write to the server. Panic on error.

func (*RemoteServer) Open 

func (s *RemoteServer) Open() error

func (RemoteServer) Query 

func (s RemoteServer) Query(query string) (results string, err error)

Query executes a query against the server and returns the results.

func (RemoteServer) QueryPromWithParams added in v1.3.0 

func (s RemoteServer) QueryPromWithParams(query string, values url.Values, path string) (string, error)

func (RemoteServer) QueryWithParams 

func (s RemoteServer) QueryWithParams(query string, values url.Values) (results string, err error)

Query executes a query against the server and returns the results.

func (*RemoteServer) Reset 

func (s *RemoteServer) Reset() error

Reset attempts to remove all database state by dropping everything

func (*RemoteServer) SetLogOutput 

func (s *RemoteServer) SetLogOutput(w io.Writer)

func (*RemoteServer) URL 

func (s *RemoteServer) URL() string

func (RemoteServer) Write 

func (s RemoteServer) Write(db, rp, body string, params url.Values) (results string, err error)

Write executes a write against the server and returns the results.

type Response 

type Response struct {
	Results []*query.Result
	Err     error
}

Response represents a list of statement results.

func (*Response) Error 

func (r *Response) Error() error

Error returns the first error from any statement. Returns nil if no errors occurred on any statements.

func (Response) MarshalJSON 

func (r Response) MarshalJSON() ([]byte, error)

MarshalJSON encodes a Response struct into JSON.

func (*Response) UnmarshalJSON 

func (r *Response) UnmarshalJSON(b []byte) error

UnmarshalJSON decodes the data into the Response struct.

type ResultItem added in v1.5.0 

type ResultItem struct {
	Error       string
	StatementId int `json:"statement_id"`
	Series      []ResultSeries
}

type ResultSeries added in v1.5.0 

type ResultSeries struct {
	Name    string
	Tags    map[string]string
	Columns []string
	Values  [][]interface{}
}

type Results added in v1.5.0 

type Results struct {
	Err     string
	Results []ResultItem
}

type Server 

type Server interface {
	URL() string
	Open() error
	SetLogOutput(w io.Writer)
	Close()
	Closed() bool

	CreateDatabase(db string) (*meta.DatabaseInfo, error)
	CreateDatabaseTagArrayEnabledAndRp(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error
	CreateDatabaseShardKey(db string, shardKey string) error
	CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error
	CreateMeasurement(mst string) error
	DropDatabase(db string) error
	Reset() error
	ContainDatabase(name string) bool

	Query(query string) (results string, err error)
	QueryWithParams(query string, values url.Values) (results string, err error)
	QueryPromWithParams(query string, values url.Values, path string) (results string, err error)

	Write(db, rp, body string, params url.Values) (results string, err error)
	MustWrite(db, rp, body string, params url.Values) string
	CheckDropDatabases(dbs []string) error
}

Server represents a test wrapper for run.Server.

func NewServer 

func NewServer(c *Config, isPromServer bool) Server

NewServer returns a new instance of Server.

func NewTSDBServer 

func NewTSDBServer(c *Config) Server

NewTSDBServer returns a new instance of Server.

func OpenDefaultServer 

func OpenDefaultServer(c *Config) Server

OpenDefaultServer opens a test server with a default database & retention policy.

func OpenPromServer added in v1.4.0 

func OpenPromServer(c *Config) Server

func OpenServer 

func OpenServer(c *Config) Server

OpenServer opens a test server.

func OpenServerWithVersion 

func OpenServerWithVersion(c *Config, version string) Server

OpenServerWithVersion opens a test server with a specific version.

func OpenTSDBServer 

func OpenTSDBServer(c *Config) Server

OpenServer opens a test server.

type Test 

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

func NewTest 

func NewTest(db, rp string) Test

type Tests 

type Tests map[string]Test

type Write 

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

type WriteError 

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

func (WriteError) Body 

func (wr WriteError) Body() string

func (WriteError) Error 

func (wr WriteError) Error() string

func (WriteError) StatusCode 

func (wr WriteError) StatusCode() int

type Writes 

type Writes []*Write

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.