v1tests

Documentation

Index

• Variables
• func OpenServer(t *testing.T, extra ...launcher.OptSetter) *tests.DefaultPipeline
• type Query
  • func (q *Query) Execute(ctx context.Context, t *testing.T, db string, c *tests.Client) (err error)
• type Test
  • func NewEmptyTest() Test
  • func NewTest(db, rp string) Test
  • func (qt *Test) Run(ctx context.Context, t *testing.T, p *tests.DefaultPipeline)
• type TestServer
  • func NewTestServer(ctx context.Context, t *testing.T, db, rp string, writes ...string) *TestServer
  • func (qr *TestServer) Execute(ctx context.Context, t *testing.T, query Query)
• type Write
• type Writes

Variables

var LosAngeles = mustParseLocation("America/Los_Angeles")

Functions

func OpenServer

func OpenServer(t *testing.T, extra ...launcher.OptSetter) *tests.DefaultPipeline

Types

type Query

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

func (*Query) Execute

func (q *Query) Execute(ctx context.Context, t *testing.T, db string, c *tests.Client) (err error)

Execute runs the command and returns an err if it fails

type Test

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

func NewEmptyTest

func NewEmptyTest() Test

NewEmptyTest creates an empty test without a default database and retention policy mapping or any expected writes.

func NewTest

func NewTest(db, rp string) Test

func (*Test) Run

func (qt *Test) Run(ctx context.Context, t *testing.T, p *tests.DefaultPipeline)

type TestServer

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

func NewTestServer

func NewTestServer(ctx context.Context, t *testing.T, db, rp string, writes ...string) *TestServer

func (*TestServer) Execute

func (qr *TestServer) Execute(ctx context.Context, t *testing.T, query Query)

type Write

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

type Writes

type Writes []*Write