package tests

import "github.com/influxdata/influxdb/tests"

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

Index ¶

• Variables
• func MustReadAll(r io.Reader) []byte
• func NewRetentionPolicySpec(name string, rf int, duration time.Duration, futureWriteLimit time.Duration, pastWriteLimit time.Duration) *meta.RetentionPolicySpec
• func RemoteEnabled() bool
• type Config
• func NewConfig() *Config
• type LocalServer
• func (s *LocalServer) Close()
• func (s *LocalServer) Closed() bool
• func (s *LocalServer) CreateDatabase(db string) (*meta.DatabaseInfo, error)
• func (s *LocalServer) CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error
• func (s *LocalServer) CreateSubscription(database, rp, name, mode string, destinations []string) error
• func (s *LocalServer) DropDatabase(db string) error
• func (s LocalServer) HTTPGet(url string) (results string, err error)
• func (s LocalServer) HTTPPost(url string, content []byte) (results string, err error)
• func (s LocalServer) MustQuery(query string) string
• func (s LocalServer) MustQueryWithParams(query string, values url.Values) string
• func (s LocalServer) MustWrite(db, rp, body string, params url.Values) string
• func (s *LocalServer) Open() error
• func (s LocalServer) Query(query string) (results string, err error)
• func (s LocalServer) QueryWithParams(query string, values url.Values) (results string, err error)
• func (s *LocalServer) Reset() error
• func (s *LocalServer) TcpAddr() string
• func (s *LocalServer) URL() string
• func (s LocalServer) Write(db, rp, body string, params url.Values) (results string, err error)
• func (s *LocalServer) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, user meta.User, points []models.Point) error
• type Query
• func (q *Query) Error(err error) string
• func (q *Query) Execute(s Server) (err error)
• type Server
• func NewServer(c *Config) Server
• func OpenDefaultServer(c *Config) Server
• func OpenServer(c *Config) Server
• func OpenServerWithVersion(c *Config, version string) Server
• type Test
• func NewTest(db, rp string) Test
• type Tests
• type Write
• type WriteError
• func (wr WriteError) Body() string
• func (wr WriteError) Error() string
• func (wr WriteError) StatusCode() int
• type Writes

Variables ¶

var LosAngeles = mustParseLocation("America/Los_Angeles")

Functions ¶

func MustReadAll ¶

func MustReadAll(r io.Reader) []byte

MustReadAll reads r. Panic on error.

func NewRetentionPolicySpec ¶

func NewRetentionPolicySpec(name string, rf int, duration time.Duration, futureWriteLimit time.Duration, pastWriteLimit 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 {
	*run.Config
	// 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.

type LocalServer ¶

type LocalServer struct {
	*run.Server

	Config *Config
	// contains filtered or unexported fields
}

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

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) 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) CreateSubscription ¶

func (s *LocalServer) CreateSubscription(database, rp, name, mode string, destinations []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) 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) TcpAddr ¶

func (s *LocalServer) TcpAddr() string

func (*LocalServer) URL ¶

func (s *LocalServer) URL() string

URL returns the base URL for the httpd endpoint.

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.

func (*LocalServer) WritePoints ¶

func (s *LocalServer) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, user meta.User, points []models.Point) error

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

type Server ¶

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

	CreateDatabase(db string) (*meta.DatabaseInfo, error)
	CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error
	CreateSubscription(database, rp, name, mode string, destinations []string) error
	DropDatabase(db string) error
	Reset() error

	Query(query string) (results string, err error)
	QueryWithParams(query string, values url.Values) (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
	WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, user meta.User, points []models.Point) error
}

Server represents a test wrapper for run.Server.

func NewServer ¶

func NewServer(c *Config) Server

NewServer 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 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.

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 ¶

server_helpers.go server_suite.go