testutil

package
Version: v0.13.13-0...-98661b4 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) 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(ctx 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(outputs []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

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:

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL