mock_pipeline

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: May 25, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package mock_pipeline is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockPayload

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

MockPayload is a mock of Payload interface

func NewMockPayload

func NewMockPayload(ctrl *gomock.Controller) *MockPayload

NewMockPayload creates a new mock instance

func (*MockPayload) EXPECT

func (m *MockPayload) EXPECT() *MockPayloadMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPayload) MarkAsProcessed

func (m *MockPayload) MarkAsProcessed()

MarkAsProcessed mocks base method

func (*MockPayload) SetCurrentHeight

func (m *MockPayload) SetCurrentHeight(arg0 int64)

SetCurrentHeight mocks base method

type MockPayloadFactory

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

MockPayloadFactory is a mock of PayloadFactory interface

func NewMockPayloadFactory

func NewMockPayloadFactory(ctrl *gomock.Controller) *MockPayloadFactory

NewMockPayloadFactory creates a new mock instance

func (*MockPayloadFactory) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockPayloadFactory) GetPayload

func (m *MockPayloadFactory) GetPayload() pipeline.Payload

GetPayload mocks base method

type MockPayloadFactoryMockRecorder

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

MockPayloadFactoryMockRecorder is the mock recorder for MockPayloadFactory

func (*MockPayloadFactoryMockRecorder) GetPayload

func (mr *MockPayloadFactoryMockRecorder) GetPayload() *gomock.Call

GetPayload indicates an expected call of GetPayload

type MockPayloadMockRecorder

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

MockPayloadMockRecorder is the mock recorder for MockPayload

func (*MockPayloadMockRecorder) MarkAsProcessed

func (mr *MockPayloadMockRecorder) MarkAsProcessed() *gomock.Call

MarkAsProcessed indicates an expected call of MarkAsProcessed

func (*MockPayloadMockRecorder) SetCurrentHeight

func (mr *MockPayloadMockRecorder) SetCurrentHeight(arg0 interface{}) *gomock.Call

SetCurrentHeight indicates an expected call of SetCurrentHeight

type MockSink

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

MockSink is a mock of Sink interface

func NewMockSink

func NewMockSink(ctrl *gomock.Controller) *MockSink

NewMockSink creates a new mock instance

func (*MockSink) Consume

func (m *MockSink) Consume(arg0 context.Context, arg1 pipeline.Payload) error

Consume mocks base method

func (*MockSink) EXPECT

func (m *MockSink) EXPECT() *MockSinkMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

type MockSinkMockRecorder

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

MockSinkMockRecorder is the mock recorder for MockSink

func (*MockSinkMockRecorder) Consume

func (mr *MockSinkMockRecorder) Consume(arg0, arg1 interface{}) *gomock.Call

Consume indicates an expected call of Consume

type MockSource

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

MockSource is a mock of Source interface

func NewMockSource

func NewMockSource(ctrl *gomock.Controller) *MockSource

NewMockSource creates a new mock instance

func (*MockSource) Current

func (m *MockSource) Current() int64

Current mocks base method

func (*MockSource) EXPECT

func (m *MockSource) EXPECT() *MockSourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSource) Err

func (m *MockSource) Err() error

Err mocks base method

func (*MockSource) Next

func (m *MockSource) Next(arg0 context.Context, arg1 pipeline.Payload) bool

Next mocks base method

type MockSourceMockRecorder

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

MockSourceMockRecorder is the mock recorder for MockSource

func (*MockSourceMockRecorder) Current

func (mr *MockSourceMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current

func (*MockSourceMockRecorder) Err

func (mr *MockSourceMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockSourceMockRecorder) Next

func (mr *MockSourceMockRecorder) Next(arg0, arg1 interface{}) *gomock.Call

Next indicates an expected call of Next

type MockStage

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

MockStage is a mock of Stage interface

func NewMockStage

func NewMockStage(ctrl *gomock.Controller) *MockStage

NewMockStage creates a new mock instance

func (*MockStage) EXPECT

func (m *MockStage) EXPECT() *MockStageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockStage) Run

func (m *MockStage) Run(arg0 context.Context, arg1 pipeline.Payload, arg2 *pipeline.Options) error

Run mocks base method

type MockStageMockRecorder

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

MockStageMockRecorder is the mock recorder for MockStage

func (*MockStageMockRecorder) Run

func (mr *MockStageMockRecorder) Run(arg0, arg1, arg2 interface{}) *gomock.Call

Run indicates an expected call of Run

type MockStageRunner

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

MockStageRunner is a mock of StageRunner interface

func NewMockStageRunner

func NewMockStageRunner(ctrl *gomock.Controller) *MockStageRunner

NewMockStageRunner creates a new mock instance

func (*MockStageRunner) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockStageRunner) Run

Run mocks base method

type MockStageRunnerMockRecorder

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

MockStageRunnerMockRecorder is the mock recorder for MockStageRunner

func (*MockStageRunnerMockRecorder) Run

func (mr *MockStageRunnerMockRecorder) Run(arg0, arg1, arg2 interface{}) *gomock.Call

Run indicates an expected call of Run

type MockTask

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

MockTask is a mock of Task interface

func NewMockTask

func NewMockTask(ctrl *gomock.Controller) *MockTask

NewMockTask creates a new mock instance

func (*MockTask) EXPECT

func (m *MockTask) EXPECT() *MockTaskMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTask) Run

func (m *MockTask) Run(arg0 context.Context, arg1 pipeline.Payload) error

Run mocks base method

type MockTaskMockRecorder

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

MockTaskMockRecorder is the mock recorder for MockTask

func (*MockTaskMockRecorder) Run

func (mr *MockTaskMockRecorder) Run(arg0, arg1 interface{}) *gomock.Call

Run indicates an expected call of Run

Jump to

Keyboard shortcuts

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