testutil

Jun 16, 2021

Changes in this version

type FakeOutput

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

Oct 6, 2020

Changes in this version

type FakeOutput

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

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

type Pipeline

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

Sep 11, 2020

Changes in this version

+ type Database struct

+ 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 OperatorBuilder struct

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

+ func (_m *OperatorBuilder) ID() string

+ func (_m *OperatorBuilder) SetNamespace(namespace string, exclude ...string)

+ func (_m *OperatorBuilder) Type() string

+ type Pipeline struct

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

+ func (_m *Pipeline) Running() bool

+ func (_m *Pipeline) Start() error

+ func (_m *Pipeline) Stop() error

Aug 24, 2020

Changes in this version

+ 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 FakeOutput struct

+ Received chan *entry.Entry

+ func NewFakeOutput(t testing.TB) *FakeOutput

+ func (f *FakeOutput) CanOutput() bool

+ func (f *FakeOutput) CanProcess() bool

+ func (f *FakeOutput) ID() string

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

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

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

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

+ func (f *FakeOutput) Start() error

+ func (f *FakeOutput) Stop() error

+ func (f *FakeOutput) Type() string

+ type Operator struct

+ 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