mock_worker_pool

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package mock_worker_pool is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockJob 

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

MockJob is a mock of Job interface

func NewMockJob 

func NewMockJob(ctrl *gomock.Controller) *MockJob

NewMockJob creates a new mock instance

func (*MockJob) BeforeWindowMoveForward 

func (m *MockJob) BeforeWindowMoveForward()

BeforeWindowMoveForward mocks base method

func (*MockJob) EXPECT 

func (m *MockJob) EXPECT() *MockJobMockRecorder

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

func (*MockJob) EventTime 

func (m *MockJob) EventTime() time.Time

EventTime mocks base method

func (*MockJob) Msg 

func (m *MockJob) Msg() core.Msg

Msg mocks base method

func (*MockJob) SequenceNumber 

func (m *MockJob) SequenceNumber() int64

SequenceNumber mocks base method

func (*MockJob) SkipDownStream 

func (m *MockJob) SkipDownStream() bool

SkipDownStream mocks base method

func (*MockJob) SlidingWindowKey 

func (m *MockJob) SlidingWindowKey() string

SlidingWindowKey mocks base method

func (*MockJob) TableKey 

func (m *MockJob) TableKey() string

TableKey mocks base method

func (*MockJob) WorkerKey 

func (m *MockJob) WorkerKey() string

WorkerKey mocks base method

type MockJobAcker 

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

MockJobAcker is a mock of JobAcker interface

func NewMockJobAcker 

func NewMockJobAcker(ctrl *gomock.Controller) *MockJobAcker

NewMockJobAcker creates a new mock instance

func (*MockJobAcker) AckJob 

func (m *MockJobAcker) AckJob(arg0 worker_pool.Job) error

AckJob mocks base method

func (*MockJobAcker) EXPECT 

func (m *MockJobAcker) EXPECT() *MockJobAckerMockRecorder

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

type MockJobAckerMockRecorder 

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

MockJobAckerMockRecorder is the mock recorder for MockJobAcker

func (*MockJobAckerMockRecorder) AckJob 

func (mr *MockJobAckerMockRecorder) AckJob(arg0 interface{}) *gomock.Call

AckJob indicates an expected call of AckJob

type MockJobMockRecorder 

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

MockJobMockRecorder is the mock recorder for MockJob

func (*MockJobMockRecorder) BeforeWindowMoveForward 

func (mr *MockJobMockRecorder) BeforeWindowMoveForward() *gomock.Call

BeforeWindowMoveForward indicates an expected call of BeforeWindowMoveForward

func (*MockJobMockRecorder) EventTime 

func (mr *MockJobMockRecorder) EventTime() *gomock.Call

EventTime indicates an expected call of EventTime

func (*MockJobMockRecorder) Msg 

func (mr *MockJobMockRecorder) Msg() *gomock.Call

Msg indicates an expected call of Msg

func (*MockJobMockRecorder) SequenceNumber 

func (mr *MockJobMockRecorder) SequenceNumber() *gomock.Call

SequenceNumber indicates an expected call of SequenceNumber

func (*MockJobMockRecorder) SkipDownStream 

func (mr *MockJobMockRecorder) SkipDownStream() *gomock.Call

SkipDownStream indicates an expected call of SkipDownStream

func (*MockJobMockRecorder) SlidingWindowKey 

func (mr *MockJobMockRecorder) SlidingWindowKey() *gomock.Call

SlidingWindowKey indicates an expected call of SlidingWindowKey

func (*MockJobMockRecorder) TableKey 

func (mr *MockJobMockRecorder) TableKey() *gomock.Call

TableKey indicates an expected call of TableKey

func (*MockJobMockRecorder) WorkerKey 

func (mr *MockJobMockRecorder) WorkerKey() *gomock.Call

WorkerKey indicates an expected call of WorkerKey

type MockJobSubmitter 

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

MockJobSubmitter is a mock of JobSubmitter interface

func NewMockJobSubmitter 

func NewMockJobSubmitter(ctrl *gomock.Controller) *MockJobSubmitter

NewMockJobSubmitter creates a new mock instance

func (*MockJobSubmitter) EXPECT 

func (m *MockJobSubmitter) EXPECT() *MockJobSubmitterMockRecorder

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

func (*MockJobSubmitter) SubmitJob 

func (m *MockJobSubmitter) SubmitJob(arg0 worker_pool.Job) error

SubmitJob mocks base method

type MockJobSubmitterMockRecorder 

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

MockJobSubmitterMockRecorder is the mock recorder for MockJobSubmitter

func (*MockJobSubmitterMockRecorder) SubmitJob 

func (mr *MockJobSubmitterMockRecorder) SubmitJob(arg0 interface{}) *gomock.Call

SubmitJob indicates an expected call of SubmitJob

type MockScheduler 

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

MockScheduler is a mock of Scheduler interface

func NewMockScheduler 

func NewMockScheduler(ctrl *gomock.Controller) *MockScheduler

NewMockScheduler creates a new mock instance

func (*MockScheduler) AckJob 

func (m *MockScheduler) AckJob(arg0 worker_pool.Job) error

AckJob mocks base method

func (*MockScheduler) Close 

func (m *MockScheduler) Close()

Close mocks base method

func (*MockScheduler) EXPECT 

func (m *MockScheduler) EXPECT() *MockSchedulerMockRecorder

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

func (*MockScheduler) Healthy 

func (m *MockScheduler) Healthy() bool

Healthy mocks base method

func (*MockScheduler) Start 

func (m *MockScheduler) Start() error

Start mocks base method

func (*MockScheduler) SubmitJob 

func (m *MockScheduler) SubmitJob(arg0 worker_pool.Job) error

SubmitJob mocks base method

type MockSchedulerMockRecorder 

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

MockSchedulerMockRecorder is the mock recorder for MockScheduler

func (*MockSchedulerMockRecorder) AckJob 

func (mr *MockSchedulerMockRecorder) AckJob(arg0 interface{}) *gomock.Call

AckJob indicates an expected call of AckJob

func (*MockSchedulerMockRecorder) Close 

func (mr *MockSchedulerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSchedulerMockRecorder) Healthy 

func (mr *MockSchedulerMockRecorder) Healthy() *gomock.Call

Healthy indicates an expected call of Healthy

func (*MockSchedulerMockRecorder) Start 

func (mr *MockSchedulerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockSchedulerMockRecorder) SubmitJob 

func (mr *MockSchedulerMockRecorder) SubmitJob(arg0 interface{}) *gomock.Call

SubmitJob indicates an expected call of SubmitJob

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.