testutil

Documentation

Index

• func NewBuildContext(t testing.TB) operator.BuildContext
• func NewTempDir(t testing.TB) string
• func NewTestDatabase(t testing.TB) *bbolt.DB
• func Trim(s string) string
• type Database
  • func (_m *Database) Close() error
  • func (_m *Database) Sync() error
  • func (_m *Database) Update(_a0 func(*bbolt.Tx) error) error
  • func (_m *Database) View(_a0 func(*bbolt.Tx) error) error
• type FakeOutput
  • func NewFakeOutput(t testing.TB) *FakeOutput
  • func (f *FakeOutput) CanOutput() bool
  • func (f *FakeOutput) CanProcess() bool
  • func (f *FakeOutput) ExpectEntry(t testing.TB, expected *entry.Entry)
  • func (f *FakeOutput) ExpectNoEntry(t testing.TB, timeout time.Duration)
  • func (f *FakeOutput) ExpectRecord(t testing.TB, record interface{})
  • func (f *FakeOutput) ID() string
  • func (f *FakeOutput) Logger() *zap.SugaredLogger
  • func (f *FakeOutput) Outputs() []operator.Operator
  • func (f *FakeOutput) Process(_ context.Context, entry *entry.Entry) error
  • func (f *FakeOutput) SetOutputs(_ []operator.Operator) error
  • func (f *FakeOutput) Start() error
  • func (f *FakeOutput) Stop() error
  • func (f *FakeOutput) Type() string
• type Operator
  • func NewMockOperator(id string) *Operator
  • func (_m *Operator) CanOutput() bool
  • func (_m *Operator) CanProcess() bool
  • func (_m *Operator) ID() string
  • func (_m *Operator) Logger() *zap.SugaredLogger
  • func (_m *Operator) Outputs() []operator.Operator
  • func (_m *Operator) Process(_a0 context.Context, _a1 *entry.Entry) error
  • func (_m *Operator) SetOutputs(_a0 []operator.Operator) error
  • func (_m *Operator) Start() error
  • func (_m *Operator) Stop() error
  • func (_m *Operator) Type() string
• type OperatorBuilder
  • func (_m *OperatorBuilder) Build(_a0 operator.BuildContext) (operator.Operator, error)
  • func (_m *OperatorBuilder) ID() string
  • func (_m *OperatorBuilder) Type() string
• type Pipeline
  • func (_m *Pipeline) Operators() []operator.Operator
  • func (_m *Pipeline) Render() ([]byte, error)
  • func (_m *Pipeline) Start() error
  • func (_m *Pipeline) Stop() error

Functions

func NewBuildContext

func NewBuildContext(t testing.TB) operator.BuildContext

NewBuildContext will return a new build context for testing

func NewTempDir

func NewTempDir(t testing.TB) string

NewTempDir will return a new temp directory for testing

func NewTestDatabase

func NewTestDatabase(t testing.TB) *bbolt.DB

NewTestDatabase will return a new database for testing

func Trim

func Trim(s string) string

Trim removes white space from the lines of a string

Types

type Database

type Database struct {
	mock.Mock
}

Database is an autogenerated mock type for the Database type

func (*Database) Close

func (_m *Database) Close() error

Close provides a mock function with given fields:

func (*Database) Sync

func (_m *Database) Sync() error

Sync provides a mock function with given fields:

func (*Database) Update

func (_m *Database) Update(_a0 func(*bbolt.Tx) error) error

Update provides a mock function with given fields: _a0

func (*Database) View

func (_m *Database) View(_a0 func(*bbolt.Tx) error) error

View provides a mock function with given fields: _a0

type FakeOutput

type FakeOutput struct {
	Received chan *entry.Entry
	*zap.SugaredLogger
}

FakeOutput is an empty output used primarily for testing

func NewFakeOutput

func NewFakeOutput(t testing.TB) *FakeOutput

NewFakeOutput creates a new fake output with default settings

func (*FakeOutput) CanOutput

func (f *FakeOutput) CanOutput() bool

CanOutput always returns false for a fake output

func (*FakeOutput) CanProcess

func (f *FakeOutput) CanProcess() bool

CanProcess always returns true for a fake output

func (*FakeOutput) ExpectEntry

func (f *FakeOutput) ExpectEntry(t testing.TB, expected *entry.Entry)

ExpectEntry expects that an entry will be received by the fake operator within a second and that it is equal to the given record

func (*FakeOutput) ExpectNoEntry

func (f *FakeOutput) ExpectNoEntry(t testing.TB, timeout time.Duration)

ExpectNoEntry expects that no entry will be received within the specified time

func (*FakeOutput) ExpectRecord

func (f *FakeOutput) ExpectRecord(t testing.TB, record interface{})

ExpectRecord expects that a record will be received by the fake operator within a second and that it is equal to the given record

func (*FakeOutput) ID

func (f *FakeOutput) ID() string

ID always returns `fake` as the ID of a fake output operator

func (*FakeOutput) Logger

func (f *FakeOutput) Logger() *zap.SugaredLogger

Logger returns the logger of a fake output

func (*FakeOutput) Outputs

func (f *FakeOutput) Outputs() []operator.Operator

Outputs always returns nil for a fake output

func (*FakeOutput) Process

func (f *FakeOutput) Process(_ context.Context, entry *entry.Entry) error

Process will place all incoming entries on the Received channel of a fake output

func (*FakeOutput) SetOutputs

func (f *FakeOutput) SetOutputs(_ []operator.Operator) error

SetOutputs immediately returns nil for a fake output

func (*FakeOutput) Start

func (f *FakeOutput) Start() error

Start immediately returns nil for a fake output

func (*FakeOutput) Stop

func (f *FakeOutput) Stop() error

Stop immediately returns nil for a fake output

func (*FakeOutput) Type

func (f *FakeOutput) Type() string

Type always return `fake_output` for a fake output

type Operator

type Operator struct {
	mock.Mock
}

Operator is an autogenerated mock type for the Operator type

func NewMockOperator

func NewMockOperator(id string) *Operator

NewMockOperator will return a basic operator mock

func (*Operator) CanOutput

func (_m *Operator) CanOutput() bool

CanOutput provides a mock function with given fields:

func (*Operator) CanProcess

func (_m *Operator) CanProcess() bool

CanProcess provides a mock function with given fields:

func (*Operator) ID

func (_m *Operator) ID() string

ID provides a mock function with given fields:

func (*Operator) Logger

func (_m *Operator) Logger() *zap.SugaredLogger

Logger provides a mock function with given fields:

func (*Operator) Outputs

func (_m *Operator) Outputs() []operator.Operator

Outputs provides a mock function with given fields:

func (*Operator) Process

func (_m *Operator) Process(_a0 context.Context, _a1 *entry.Entry) error

Process provides a mock function with given fields: _a0, _a1

func (*Operator) SetOutputs

func (_m *Operator) SetOutputs(_a0 []operator.Operator) error

SetOutputs provides a mock function with given fields: _a0

func (*Operator) Start

func (_m *Operator) Start() error

Start provides a mock function with given fields:

func (*Operator) Stop

func (_m *Operator) Stop() error

Stop provides a mock function with given fields:

func (*Operator) Type

func (_m *Operator) Type() string

Type provides a mock function with given fields:

type OperatorBuilder

type OperatorBuilder struct {
	mock.Mock
}

OperatorBuilder is an autogenerated mock type for the Builder type

func (*OperatorBuilder) Build

func (_m *OperatorBuilder) Build(_a0 operator.BuildContext) (operator.Operator, error)

Build provides a mock function with given fields: _a0

func (*OperatorBuilder) ID

func (_m *OperatorBuilder) ID() string

ID provides a mock function with given fields:

func (*OperatorBuilder) Type

func (_m *OperatorBuilder) Type() string

Type provides a mock function with given fields:

type Pipeline

type Pipeline struct {
	mock.Mock
}

Pipeline is an autogenerated mock type for the Pipeline type

func (*Pipeline) Operators

func (_m *Pipeline) Operators() []operator.Operator

Operators provides a mock function with given fields:

func (*Pipeline) Render

func (_m *Pipeline) Render() ([]byte, error)

Render provides a mock function with given fields:

func (*Pipeline) Start

func (_m *Pipeline) Start() error

Start provides a mock function with given fields:

func (*Pipeline) Stop

func (_m *Pipeline) Stop() error

Stop provides a mock function with given fields: