testing

Documentation

Overview

Package testing is a test suit for recorders. They should provide an object that implements the Constructor interface then run:

import rt "github.com/arsham/expipe/recorder/testing"
....
r, err := rt.New()
if err != nil {
    panic(err)
}
c := &Construct{r, getTestServer()}
rt.TestSuites(t, c, func() {/*clean up code*/})

The test suit will pick it up and does all the tests.

Important Note

You need to write the edge cases if they are not covered in this section.

Index

• func TestSuites(t *testing.T, setup func() (Constructor, func()))
• type Config
  • func (c *Config) Backoff() int
  • func (c *Config) Endpoint() string
  • func (c *Config) IndexName() string
  • func (c *Config) Logger() internal.FieldLogger
  • func (c *Config) Name() string
  • func (c *Config) NewInstance() (recorder.DataRecorder, error)
  • func (c *Config) Timeout() time.Duration
• type Constructor
• type Recorder
  • func GetRecorder(url string) *Recorder
  • func New(options ...func(recorder.Constructor) error) (*Recorder, error)
  • func (r *Recorder) Backoff() int
  • func (r *Recorder) Endpoint() string
  • func (r *Recorder) IndexName() string
  • func (r *Recorder) Logger() internal.FieldLogger
  • func (r *Recorder) Name() string
  • func (r *Recorder) Ping() error
  • func (r *Recorder) Record(ctx context.Context, job *recorder.Job) error
  • func (r *Recorder) SetBackoff(backoff int)
  • func (r *Recorder) SetEndpoint(endpoint string)
  • func (r *Recorder) SetIndexName(indexName string)
  • func (r *Recorder) SetLogger(log internal.FieldLogger)
  • func (r *Recorder) SetName(name string)
  • func (r *Recorder) SetTimeout(timeout time.Duration)
  • func (r *Recorder) Timeout() time.Duration

Functions

func TestSuites

func TestSuites(t *testing.T, setup func() (Constructor, func()))

TestSuites returns a map of test name to the runner function.

Types

type Config

type Config struct {
	MockName      string
	MockEndpoint  string
	MockTimeout   time.Duration
	MockBackoff   int
	MockIndexName string
	MockLogger    internal.FieldLogger
}

Config holds the necessary configuration for setting up an elasticsearch recorder endpoint.

func (*Config) Backoff

func (c *Config) Backoff() int

Backoff is the mocked version.

func (*Config) Endpoint

func (c *Config) Endpoint() string

Endpoint is the mocked version.

func (*Config) IndexName

func (c *Config) IndexName() string

IndexName is the mocked version.

func (*Config) Logger

func (c *Config) Logger() internal.FieldLogger

Logger is the mocked version.

func (*Config) Name

func (c *Config) Name() string

Name is the mocked version.

func (*Config) NewInstance

func (c *Config) NewInstance() (recorder.DataRecorder, error)

NewInstance returns a mocked object.

func (*Config) Timeout

func (c *Config) Timeout() time.Duration

Timeout is the mocked version.

type Constructor

type Constructor interface {
	recorder.Constructor
	ValidEndpoints() []string
	InvalidEndpoints() []string
	TestServer() *httptest.Server
	Object() (recorder.DataRecorder, error)
}

Constructor is an interface for setting up an object for testing. TestServer() should return a ready to use test server

type Recorder

type Recorder struct {
	ErrorFunc  func() error
	Smu        sync.RWMutex
	RecordFunc func(context.Context, *recorder.Job) error
	Pinged     bool
	// contains filtered or unexported fields
}

Recorder is designed to be used in tests.

func GetRecorder

func GetRecorder(url string) *Recorder

GetRecorder provides a SimpleRecorder for using in the example.

func New

func New(options ...func(recorder.Constructor) error) (*Recorder, error)

New is a recorder for using in tests.

func (*Recorder) Backoff

func (r *Recorder) Backoff() int

Backoff returns the backoff.

func (*Recorder) Endpoint

func (r *Recorder) Endpoint() string

Endpoint returns the endpoint.

func (*Recorder) IndexName

func (r *Recorder) IndexName() string

IndexName returns the index name.

func (*Recorder) Logger

func (r *Recorder) Logger() internal.FieldLogger

Logger returns the log.

func (*Recorder) Name

func (r *Recorder) Name() string

Name returns the name.

func (*Recorder) Ping

func (r *Recorder) Ping() error

Ping pings the endpoint and return nil if was successful.

func (*Recorder) Record

func (r *Recorder) Record(ctx context.Context, job *recorder.Job) error

Record calls the RecordFunc if exists, otherwise continues as normal.

func (*Recorder) SetBackoff

func (r *Recorder) SetBackoff(backoff int)

SetBackoff sets the backoff of the recorder.

func (*Recorder) SetEndpoint

func (r *Recorder) SetEndpoint(endpoint string)

SetEndpoint sets the endpoint of the recorder.

func (*Recorder) SetIndexName

func (r *Recorder) SetIndexName(indexName string)

SetIndexName sets the index name of the recorder.

func (*Recorder) SetLogger

func (r *Recorder) SetLogger(log internal.FieldLogger)

SetLogger sets the log of the recorder.

func (*Recorder) SetName

func (r *Recorder) SetName(name string)

SetName sets the name of the recorder.

func (*Recorder) SetTimeout

func (r *Recorder) SetTimeout(timeout time.Duration)

SetTimeout sets the timeout of the recorder.

func (*Recorder) Timeout

func (r *Recorder) Timeout() time.Duration

Timeout returns the timeout.