Documentation ¶
Overview ¶
Package sourcemock is a generated GoMock package.
Index ¶
- type MockSourceClient
- func (m *MockSourceClient) AckFn(arg0 context.Context, arg1 *v1.AckRequest, arg2 ...grpc.CallOption) (*v1.AckResponse, error)
- func (m *MockSourceClient) EXPECT() *MockSourceClientMockRecorder
- func (m *MockSourceClient) IsReady(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*v1.ReadyResponse, error)
- func (m *MockSourceClient) PendingFn(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*v1.PendingResponse, error)
- func (m *MockSourceClient) ReadFn(arg0 context.Context, arg1 *v1.ReadRequest, arg2 ...grpc.CallOption) (v1.Source_ReadFnClient, error)
- type MockSourceClientMockRecorder
- func (mr *MockSourceClientMockRecorder) AckFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockSourceClientMockRecorder) IsReady(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockSourceClientMockRecorder) PendingFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockSourceClientMockRecorder) ReadFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockSource_ReadFnClient
- func (m *MockSource_ReadFnClient) CloseSend() error
- func (m *MockSource_ReadFnClient) Context() context.Context
- func (m *MockSource_ReadFnClient) EXPECT() *MockSource_ReadFnClientMockRecorder
- func (m *MockSource_ReadFnClient) Header() (metadata.MD, error)
- func (m *MockSource_ReadFnClient) Recv() (*v1.ReadResponse, error)
- func (m *MockSource_ReadFnClient) RecvMsg(arg0 interface{}) error
- func (m *MockSource_ReadFnClient) SendMsg(arg0 interface{}) error
- func (m *MockSource_ReadFnClient) Trailer() metadata.MD
- type MockSource_ReadFnClientMockRecorder
- func (mr *MockSource_ReadFnClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) Context() *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) Header() *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) Recv() *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockSource_ReadFnClientMockRecorder) Trailer() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockSourceClient ¶
type MockSourceClient struct {
// contains filtered or unexported fields
}
MockSourceClient is a mock of SourceClient interface.
func NewMockSourceClient ¶
func NewMockSourceClient(ctrl *gomock.Controller) *MockSourceClient
NewMockSourceClient creates a new mock instance.
func (*MockSourceClient) AckFn ¶
func (m *MockSourceClient) AckFn(arg0 context.Context, arg1 *v1.AckRequest, arg2 ...grpc.CallOption) (*v1.AckResponse, error)
AckFn mocks base method.
func (*MockSourceClient) EXPECT ¶
func (m *MockSourceClient) EXPECT() *MockSourceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSourceClient) IsReady ¶
func (m *MockSourceClient) IsReady(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*v1.ReadyResponse, error)
IsReady mocks base method.
func (*MockSourceClient) PendingFn ¶
func (m *MockSourceClient) PendingFn(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*v1.PendingResponse, error)
PendingFn mocks base method.
func (*MockSourceClient) ReadFn ¶
func (m *MockSourceClient) ReadFn(arg0 context.Context, arg1 *v1.ReadRequest, arg2 ...grpc.CallOption) (v1.Source_ReadFnClient, error)
ReadFn mocks base method.
type MockSourceClientMockRecorder ¶
type MockSourceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSourceClientMockRecorder is the mock recorder for MockSourceClient.
func (*MockSourceClientMockRecorder) AckFn ¶
func (mr *MockSourceClientMockRecorder) AckFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
AckFn indicates an expected call of AckFn.
func (*MockSourceClientMockRecorder) IsReady ¶
func (mr *MockSourceClientMockRecorder) IsReady(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
IsReady indicates an expected call of IsReady.
func (*MockSourceClientMockRecorder) PendingFn ¶
func (mr *MockSourceClientMockRecorder) PendingFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PendingFn indicates an expected call of PendingFn.
func (*MockSourceClientMockRecorder) ReadFn ¶
func (mr *MockSourceClientMockRecorder) ReadFn(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ReadFn indicates an expected call of ReadFn.
type MockSource_ReadFnClient ¶
type MockSource_ReadFnClient struct {
// contains filtered or unexported fields
}
MockSource_ReadFnClient is a mock of Source_ReadFnClient interface.
func NewMockSource_ReadFnClient ¶
func NewMockSource_ReadFnClient(ctrl *gomock.Controller) *MockSource_ReadFnClient
NewMockSource_ReadFnClient creates a new mock instance.
func (*MockSource_ReadFnClient) CloseSend ¶
func (m *MockSource_ReadFnClient) CloseSend() error
CloseSend mocks base method.
func (*MockSource_ReadFnClient) Context ¶
func (m *MockSource_ReadFnClient) Context() context.Context
Context mocks base method.
func (*MockSource_ReadFnClient) EXPECT ¶
func (m *MockSource_ReadFnClient) EXPECT() *MockSource_ReadFnClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSource_ReadFnClient) Header ¶
func (m *MockSource_ReadFnClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockSource_ReadFnClient) Recv ¶
func (m *MockSource_ReadFnClient) Recv() (*v1.ReadResponse, error)
Recv mocks base method.
func (*MockSource_ReadFnClient) RecvMsg ¶
func (m *MockSource_ReadFnClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockSource_ReadFnClient) SendMsg ¶
func (m *MockSource_ReadFnClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockSource_ReadFnClient) Trailer ¶
func (m *MockSource_ReadFnClient) Trailer() metadata.MD
Trailer mocks base method.
type MockSource_ReadFnClientMockRecorder ¶
type MockSource_ReadFnClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSource_ReadFnClientMockRecorder is the mock recorder for MockSource_ReadFnClient.
func (*MockSource_ReadFnClientMockRecorder) CloseSend ¶
func (mr *MockSource_ReadFnClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockSource_ReadFnClientMockRecorder) Context ¶
func (mr *MockSource_ReadFnClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockSource_ReadFnClientMockRecorder) Header ¶
func (mr *MockSource_ReadFnClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockSource_ReadFnClientMockRecorder) Recv ¶
func (mr *MockSource_ReadFnClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockSource_ReadFnClientMockRecorder) RecvMsg ¶
func (mr *MockSource_ReadFnClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockSource_ReadFnClientMockRecorder) SendMsg ¶
func (mr *MockSource_ReadFnClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockSource_ReadFnClientMockRecorder) Trailer ¶
func (mr *MockSource_ReadFnClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.