Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockJobQueue_JobStreamServer
- func (m *MockJobQueue_JobStreamServer) Context() context.Context
- func (m *MockJobQueue_JobStreamServer) EXPECT() *MockJobQueue_JobStreamServerMockRecorder
- func (m *MockJobQueue_JobStreamServer) Recv() (*proto.WorkerPayload, error)
- func (m *MockJobQueue_JobStreamServer) RecvMsg(arg0 interface{}) error
- func (m *MockJobQueue_JobStreamServer) Send(arg0 *proto.MasterPayload) error
- func (m *MockJobQueue_JobStreamServer) SendHeader(arg0 metadata.MD) error
- func (m *MockJobQueue_JobStreamServer) SendMsg(arg0 interface{}) error
- func (m *MockJobQueue_JobStreamServer) SetHeader(arg0 metadata.MD) error
- func (m *MockJobQueue_JobStreamServer) SetTrailer(arg0 metadata.MD)
- type MockJobQueue_JobStreamServerMockRecorder
- func (mr *MockJobQueue_JobStreamServerMockRecorder) Context() *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) Recv() *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockJobQueue_JobStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockRunner
- type MockRunnerMockRecorder
- type MockSerializer
- type MockSerializerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockJobQueue_JobStreamServer ¶
type MockJobQueue_JobStreamServer struct {
// contains filtered or unexported fields
}
MockJobQueue_JobStreamServer is a mock of JobQueue_JobStreamServer interface
func NewMockJobQueue_JobStreamServer ¶
func NewMockJobQueue_JobStreamServer(ctrl *gomock.Controller) *MockJobQueue_JobStreamServer
NewMockJobQueue_JobStreamServer creates a new mock instance
func (*MockJobQueue_JobStreamServer) Context ¶
func (m *MockJobQueue_JobStreamServer) Context() context.Context
Context mocks base method
func (*MockJobQueue_JobStreamServer) EXPECT ¶
func (m *MockJobQueue_JobStreamServer) EXPECT() *MockJobQueue_JobStreamServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockJobQueue_JobStreamServer) Recv ¶
func (m *MockJobQueue_JobStreamServer) Recv() (*proto.WorkerPayload, error)
Recv mocks base method
func (*MockJobQueue_JobStreamServer) RecvMsg ¶
func (m *MockJobQueue_JobStreamServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockJobQueue_JobStreamServer) Send ¶
func (m *MockJobQueue_JobStreamServer) Send(arg0 *proto.MasterPayload) error
Send mocks base method
func (*MockJobQueue_JobStreamServer) SendHeader ¶
func (m *MockJobQueue_JobStreamServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method
func (*MockJobQueue_JobStreamServer) SendMsg ¶
func (m *MockJobQueue_JobStreamServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockJobQueue_JobStreamServer) SetHeader ¶
func (m *MockJobQueue_JobStreamServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method
func (*MockJobQueue_JobStreamServer) SetTrailer ¶
func (m *MockJobQueue_JobStreamServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method
type MockJobQueue_JobStreamServerMockRecorder ¶
type MockJobQueue_JobStreamServerMockRecorder struct {
// contains filtered or unexported fields
}
MockJobQueue_JobStreamServerMockRecorder is the mock recorder for MockJobQueue_JobStreamServer
func (*MockJobQueue_JobStreamServerMockRecorder) Context ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockJobQueue_JobStreamServerMockRecorder) Recv ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockJobQueue_JobStreamServerMockRecorder) RecvMsg ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockJobQueue_JobStreamServerMockRecorder) Send ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockJobQueue_JobStreamServerMockRecorder) SendHeader ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockJobQueue_JobStreamServerMockRecorder) SendMsg ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockJobQueue_JobStreamServerMockRecorder) SetHeader ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockJobQueue_JobStreamServerMockRecorder) SetTrailer ¶
func (mr *MockJobQueue_JobStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockRunner ¶
type MockRunner struct {
// contains filtered or unexported fields
}
MockRunner is a mock of Runner interface
func NewMockRunner ¶
func NewMockRunner(ctrl *gomock.Controller) *MockRunner
NewMockRunner creates a new mock instance
func (*MockRunner) AbortJob ¶
func (m *MockRunner) AbortJob(arg0 job.Details)
AbortJob mocks base method
func (*MockRunner) CompleteJob ¶
func (m *MockRunner) CompleteJob(arg0 job.Details) error
CompleteJob mocks base method
func (*MockRunner) EXPECT ¶
func (m *MockRunner) EXPECT() *MockRunnerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockRunner) StartJob ¶
func (m *MockRunner) StartJob(arg0 job.Details, arg1 bspgraph.ExecutorFactory) (*bspgraph.Executor, error)
StartJob mocks base method
type MockRunnerMockRecorder ¶
type MockRunnerMockRecorder struct {
// contains filtered or unexported fields
}
MockRunnerMockRecorder is the mock recorder for MockRunner
func (*MockRunnerMockRecorder) AbortJob ¶
func (mr *MockRunnerMockRecorder) AbortJob(arg0 interface{}) *gomock.Call
AbortJob indicates an expected call of AbortJob
func (*MockRunnerMockRecorder) CompleteJob ¶
func (mr *MockRunnerMockRecorder) CompleteJob(arg0 interface{}) *gomock.Call
CompleteJob indicates an expected call of CompleteJob
func (*MockRunnerMockRecorder) StartJob ¶
func (mr *MockRunnerMockRecorder) StartJob(arg0, arg1 interface{}) *gomock.Call
StartJob indicates an expected call of StartJob
type MockSerializer ¶
type MockSerializer struct {
// contains filtered or unexported fields
}
MockSerializer is a mock of Serializer interface
func NewMockSerializer ¶
func NewMockSerializer(ctrl *gomock.Controller) *MockSerializer
NewMockSerializer creates a new mock instance
func (*MockSerializer) EXPECT ¶
func (m *MockSerializer) EXPECT() *MockSerializerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSerializer) Serialize ¶
func (m *MockSerializer) Serialize(arg0 interface{}) (*any.Any, error)
Serialize mocks base method
func (*MockSerializer) Unserialize ¶
func (m *MockSerializer) Unserialize(arg0 *any.Any) (interface{}, error)
Unserialize mocks base method
type MockSerializerMockRecorder ¶
type MockSerializerMockRecorder struct {
// contains filtered or unexported fields
}
MockSerializerMockRecorder is the mock recorder for MockSerializer
func (*MockSerializerMockRecorder) Serialize ¶
func (mr *MockSerializerMockRecorder) Serialize(arg0 interface{}) *gomock.Call
Serialize indicates an expected call of Serialize
func (*MockSerializerMockRecorder) Unserialize ¶
func (mr *MockSerializerMockRecorder) Unserialize(arg0 interface{}) *gomock.Call
Unserialize indicates an expected call of Unserialize