Documentation ¶
Overview ¶
Package mock_processor is a generated GoMock package.
Index ¶
- type MockProcessorClient
- func (m *MockProcessorClient) EXPECT() *MockProcessorClientMockRecorder
- func (m *MockProcessorClient) RegisterProcess(arg0 context.Context, arg1 *processor.Process, arg2 ...grpc.CallOption) (*processor.RegisteredMessage, error)
- func (m *MockProcessorClient) RegisterStreamProcess(arg0 context.Context, arg1 ...grpc.CallOption) (processor.Processor_RegisterStreamProcessClient, error)
- func (m *MockProcessorClient) RequestNotification(arg0 context.Context, arg1 *processor.NotificationRequest, ...) (processor.Processor_RequestNotificationClient, error)
- type MockProcessorClientMockRecorder
- func (mr *MockProcessorClientMockRecorder) RegisterProcess(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockProcessorClientMockRecorder) RegisterStreamProcess(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockProcessorClientMockRecorder) RequestNotification(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockProcessor_RegisterStreamProcessClient
- func (m *MockProcessor_RegisterStreamProcessClient) CloseSend() error
- func (m *MockProcessor_RegisterStreamProcessClient) Context() context.Context
- func (m *MockProcessor_RegisterStreamProcessClient) EXPECT() *MockProcessor_RegisterStreamProcessClientMockRecorder
- func (m *MockProcessor_RegisterStreamProcessClient) Header() (metadata.MD, error)
- func (m *MockProcessor_RegisterStreamProcessClient) Recv() (*processor.RegisteredMessage, error)
- func (m *MockProcessor_RegisterStreamProcessClient) RecvMsg(arg0 interface{}) error
- func (m *MockProcessor_RegisterStreamProcessClient) Send(arg0 *processor.Process) error
- func (m *MockProcessor_RegisterStreamProcessClient) SendMsg(arg0 interface{}) error
- func (m *MockProcessor_RegisterStreamProcessClient) Trailer() metadata.MD
- type MockProcessor_RegisterStreamProcessClientMockRecorder
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Context() *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Header() *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Recv() *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Trailer() *gomock.Call
- type MockProcessor_RequestNotificationClient
- func (m *MockProcessor_RequestNotificationClient) CloseSend() error
- func (m *MockProcessor_RequestNotificationClient) Context() context.Context
- func (m *MockProcessor_RequestNotificationClient) EXPECT() *MockProcessor_RequestNotificationClientMockRecorder
- func (m *MockProcessor_RequestNotificationClient) Header() (metadata.MD, error)
- func (m *MockProcessor_RequestNotificationClient) Recv() (*processor.Notification, error)
- func (m *MockProcessor_RequestNotificationClient) RecvMsg(arg0 interface{}) error
- func (m *MockProcessor_RequestNotificationClient) SendMsg(arg0 interface{}) error
- func (m *MockProcessor_RequestNotificationClient) Trailer() metadata.MD
- type MockProcessor_RequestNotificationClientMockRecorder
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) Context() *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) Header() *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) Recv() *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockProcessor_RequestNotificationClientMockRecorder) Trailer() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockProcessorClient ¶
type MockProcessorClient struct {
// contains filtered or unexported fields
}
MockProcessorClient is a mock of ProcessorClient interface
func NewMockProcessorClient ¶
func NewMockProcessorClient(ctrl *gomock.Controller) *MockProcessorClient
NewMockProcessorClient creates a new mock instance
func (*MockProcessorClient) EXPECT ¶
func (m *MockProcessorClient) EXPECT() *MockProcessorClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProcessorClient) RegisterProcess ¶
func (m *MockProcessorClient) RegisterProcess(arg0 context.Context, arg1 *processor.Process, arg2 ...grpc.CallOption) (*processor.RegisteredMessage, error)
RegisterProcess mocks base method
func (*MockProcessorClient) RegisterStreamProcess ¶
func (m *MockProcessorClient) RegisterStreamProcess(arg0 context.Context, arg1 ...grpc.CallOption) (processor.Processor_RegisterStreamProcessClient, error)
RegisterStreamProcess mocks base method
func (*MockProcessorClient) RequestNotification ¶
func (m *MockProcessorClient) RequestNotification(arg0 context.Context, arg1 *processor.NotificationRequest, arg2 ...grpc.CallOption) (processor.Processor_RequestNotificationClient, error)
RequestNotification mocks base method
type MockProcessorClientMockRecorder ¶
type MockProcessorClientMockRecorder struct {
// contains filtered or unexported fields
}
MockProcessorClientMockRecorder is the mock recorder for MockProcessorClient
func (*MockProcessorClientMockRecorder) RegisterProcess ¶
func (mr *MockProcessorClientMockRecorder) RegisterProcess(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterProcess indicates an expected call of RegisterProcess
func (*MockProcessorClientMockRecorder) RegisterStreamProcess ¶
func (mr *MockProcessorClientMockRecorder) RegisterStreamProcess(arg0 interface{}, arg1 ...interface{}) *gomock.Call
RegisterStreamProcess indicates an expected call of RegisterStreamProcess
func (*MockProcessorClientMockRecorder) RequestNotification ¶
func (mr *MockProcessorClientMockRecorder) RequestNotification(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RequestNotification indicates an expected call of RequestNotification
type MockProcessor_RegisterStreamProcessClient ¶
type MockProcessor_RegisterStreamProcessClient struct {
// contains filtered or unexported fields
}
MockProcessor_RegisterStreamProcessClient is a mock of Processor_RegisterStreamProcessClient interface
func NewMockProcessor_RegisterStreamProcessClient ¶
func NewMockProcessor_RegisterStreamProcessClient(ctrl *gomock.Controller) *MockProcessor_RegisterStreamProcessClient
NewMockProcessor_RegisterStreamProcessClient creates a new mock instance
func (*MockProcessor_RegisterStreamProcessClient) CloseSend ¶
func (m *MockProcessor_RegisterStreamProcessClient) CloseSend() error
CloseSend mocks base method
func (*MockProcessor_RegisterStreamProcessClient) Context ¶
func (m *MockProcessor_RegisterStreamProcessClient) Context() context.Context
Context mocks base method
func (*MockProcessor_RegisterStreamProcessClient) EXPECT ¶
func (m *MockProcessor_RegisterStreamProcessClient) EXPECT() *MockProcessor_RegisterStreamProcessClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProcessor_RegisterStreamProcessClient) Header ¶
func (m *MockProcessor_RegisterStreamProcessClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockProcessor_RegisterStreamProcessClient) Recv ¶
func (m *MockProcessor_RegisterStreamProcessClient) Recv() (*processor.RegisteredMessage, error)
Recv mocks base method
func (*MockProcessor_RegisterStreamProcessClient) RecvMsg ¶
func (m *MockProcessor_RegisterStreamProcessClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockProcessor_RegisterStreamProcessClient) Send ¶
func (m *MockProcessor_RegisterStreamProcessClient) Send(arg0 *processor.Process) error
Send mocks base method
func (*MockProcessor_RegisterStreamProcessClient) SendMsg ¶
func (m *MockProcessor_RegisterStreamProcessClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockProcessor_RegisterStreamProcessClient) Trailer ¶
func (m *MockProcessor_RegisterStreamProcessClient) Trailer() metadata.MD
Trailer mocks base method
type MockProcessor_RegisterStreamProcessClientMockRecorder ¶
type MockProcessor_RegisterStreamProcessClientMockRecorder struct {
// contains filtered or unexported fields
}
MockProcessor_RegisterStreamProcessClientMockRecorder is the mock recorder for MockProcessor_RegisterStreamProcessClient
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) CloseSend ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) Context ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) Header ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) Recv ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) RecvMsg ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) Send ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) SendMsg ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockProcessor_RegisterStreamProcessClientMockRecorder) Trailer ¶
func (mr *MockProcessor_RegisterStreamProcessClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer
type MockProcessor_RequestNotificationClient ¶
type MockProcessor_RequestNotificationClient struct {
// contains filtered or unexported fields
}
MockProcessor_RequestNotificationClient is a mock of Processor_RequestNotificationClient interface
func NewMockProcessor_RequestNotificationClient ¶
func NewMockProcessor_RequestNotificationClient(ctrl *gomock.Controller) *MockProcessor_RequestNotificationClient
NewMockProcessor_RequestNotificationClient creates a new mock instance
func (*MockProcessor_RequestNotificationClient) CloseSend ¶
func (m *MockProcessor_RequestNotificationClient) CloseSend() error
CloseSend mocks base method
func (*MockProcessor_RequestNotificationClient) Context ¶
func (m *MockProcessor_RequestNotificationClient) Context() context.Context
Context mocks base method
func (*MockProcessor_RequestNotificationClient) EXPECT ¶
func (m *MockProcessor_RequestNotificationClient) EXPECT() *MockProcessor_RequestNotificationClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProcessor_RequestNotificationClient) Header ¶
func (m *MockProcessor_RequestNotificationClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockProcessor_RequestNotificationClient) Recv ¶
func (m *MockProcessor_RequestNotificationClient) Recv() (*processor.Notification, error)
Recv mocks base method
func (*MockProcessor_RequestNotificationClient) RecvMsg ¶
func (m *MockProcessor_RequestNotificationClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockProcessor_RequestNotificationClient) SendMsg ¶
func (m *MockProcessor_RequestNotificationClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockProcessor_RequestNotificationClient) Trailer ¶
func (m *MockProcessor_RequestNotificationClient) Trailer() metadata.MD
Trailer mocks base method
type MockProcessor_RequestNotificationClientMockRecorder ¶
type MockProcessor_RequestNotificationClientMockRecorder struct {
// contains filtered or unexported fields
}
MockProcessor_RequestNotificationClientMockRecorder is the mock recorder for MockProcessor_RequestNotificationClient
func (*MockProcessor_RequestNotificationClientMockRecorder) CloseSend ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockProcessor_RequestNotificationClientMockRecorder) Context ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockProcessor_RequestNotificationClientMockRecorder) Header ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockProcessor_RequestNotificationClientMockRecorder) Recv ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockProcessor_RequestNotificationClientMockRecorder) RecvMsg ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockProcessor_RequestNotificationClientMockRecorder) SendMsg ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockProcessor_RequestNotificationClientMockRecorder) Trailer ¶
func (mr *MockProcessor_RequestNotificationClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer