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 MockHaraqaClient
- func (m *MockHaraqaClient) CreateTopic(arg0 context.Context, arg1 *protocol.CreateTopicRequest, ...) (*protocol.CreateTopicResponse, error)
- func (m *MockHaraqaClient) DeleteTopic(arg0 context.Context, arg1 *protocol.DeleteTopicRequest, ...) (*protocol.DeleteTopicResponse, error)
- func (m *MockHaraqaClient) EXPECT() *MockHaraqaClientMockRecorder
- func (m *MockHaraqaClient) ListTopics(arg0 context.Context, arg1 *protocol.ListTopicsRequest, ...) (*protocol.ListTopicsResponse, error)
- func (m *MockHaraqaClient) Lock(arg0 context.Context, arg1 ...grpc.CallOption) (protocol.Haraqa_LockClient, error)
- func (m *MockHaraqaClient) Offsets(arg0 context.Context, arg1 *protocol.OffsetRequest, arg2 ...grpc.CallOption) (*protocol.OffsetResponse, error)
- func (m *MockHaraqaClient) TruncateTopic(arg0 context.Context, arg1 *protocol.TruncateTopicRequest, ...) (*protocol.TruncateTopicResponse, error)
- func (m *MockHaraqaClient) WatchTopics(arg0 context.Context, arg1 ...grpc.CallOption) (protocol.Haraqa_WatchTopicsClient, error)
- type MockHaraqaClientMockRecorder
- func (mr *MockHaraqaClientMockRecorder) CreateTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) DeleteTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) ListTopics(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) Lock(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) Offsets(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) TruncateTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHaraqaClientMockRecorder) WatchTopics(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- type MockHaraqa_LockClient
- func (m *MockHaraqa_LockClient) CloseSend() error
- func (m *MockHaraqa_LockClient) Context() context.Context
- func (m *MockHaraqa_LockClient) EXPECT() *MockHaraqa_LockClientMockRecorder
- func (m *MockHaraqa_LockClient) Header() (metadata.MD, error)
- func (m *MockHaraqa_LockClient) Recv() (*protocol.LockResponse, error)
- func (m *MockHaraqa_LockClient) RecvMsg(arg0 interface{}) error
- func (m *MockHaraqa_LockClient) Send(arg0 *protocol.LockRequest) error
- func (m *MockHaraqa_LockClient) SendMsg(arg0 interface{}) error
- func (m *MockHaraqa_LockClient) Trailer() metadata.MD
- type MockHaraqa_LockClientMockRecorder
- func (mr *MockHaraqa_LockClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) Context() *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) Header() *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) Recv() *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockClientMockRecorder) Trailer() *gomock.Call
- type MockHaraqa_LockServer
- func (m *MockHaraqa_LockServer) Context() context.Context
- func (m *MockHaraqa_LockServer) EXPECT() *MockHaraqa_LockServerMockRecorder
- func (m *MockHaraqa_LockServer) Recv() (*protocol.LockRequest, error)
- func (m *MockHaraqa_LockServer) RecvMsg(arg0 interface{}) error
- func (m *MockHaraqa_LockServer) Send(arg0 *protocol.LockResponse) error
- func (m *MockHaraqa_LockServer) SendHeader(arg0 metadata.MD) error
- func (m *MockHaraqa_LockServer) SendMsg(arg0 interface{}) error
- func (m *MockHaraqa_LockServer) SetHeader(arg0 metadata.MD) error
- func (m *MockHaraqa_LockServer) SetTrailer(arg0 metadata.MD)
- type MockHaraqa_LockServerMockRecorder
- func (mr *MockHaraqa_LockServerMockRecorder) Context() *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) Recv() *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_LockServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockHaraqa_WatchTopicsClient
- func (m *MockHaraqa_WatchTopicsClient) CloseSend() error
- func (m *MockHaraqa_WatchTopicsClient) Context() context.Context
- func (m *MockHaraqa_WatchTopicsClient) EXPECT() *MockHaraqa_WatchTopicsClientMockRecorder
- func (m *MockHaraqa_WatchTopicsClient) Header() (metadata.MD, error)
- func (m *MockHaraqa_WatchTopicsClient) Recv() (*protocol.WatchResponse, error)
- func (m *MockHaraqa_WatchTopicsClient) RecvMsg(arg0 interface{}) error
- func (m *MockHaraqa_WatchTopicsClient) Send(arg0 *protocol.WatchRequest) error
- func (m *MockHaraqa_WatchTopicsClient) SendMsg(arg0 interface{}) error
- func (m *MockHaraqa_WatchTopicsClient) Trailer() metadata.MD
- type MockHaraqa_WatchTopicsClientMockRecorder
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Context() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Header() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Recv() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Trailer() *gomock.Call
- type MockHaraqa_WatchTopicsServer
- func (m *MockHaraqa_WatchTopicsServer) Context() context.Context
- func (m *MockHaraqa_WatchTopicsServer) EXPECT() *MockHaraqa_WatchTopicsServerMockRecorder
- func (m *MockHaraqa_WatchTopicsServer) Recv() (*protocol.WatchRequest, error)
- func (m *MockHaraqa_WatchTopicsServer) RecvMsg(arg0 interface{}) error
- func (m *MockHaraqa_WatchTopicsServer) Send(arg0 *protocol.WatchResponse) error
- func (m *MockHaraqa_WatchTopicsServer) SendHeader(arg0 metadata.MD) error
- func (m *MockHaraqa_WatchTopicsServer) SendMsg(arg0 interface{}) error
- func (m *MockHaraqa_WatchTopicsServer) SetHeader(arg0 metadata.MD) error
- func (m *MockHaraqa_WatchTopicsServer) SetTrailer(arg0 metadata.MD)
- type MockHaraqa_WatchTopicsServerMockRecorder
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Context() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Recv() *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockReadWriteCloser
- type MockReadWriteCloserMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockHaraqaClient ¶
type MockHaraqaClient struct {
// contains filtered or unexported fields
}
MockHaraqaClient is a mock of HaraqaClient interface
func NewMockHaraqaClient ¶
func NewMockHaraqaClient(ctrl *gomock.Controller) *MockHaraqaClient
NewMockHaraqaClient creates a new mock instance
func (*MockHaraqaClient) CreateTopic ¶
func (m *MockHaraqaClient) CreateTopic(arg0 context.Context, arg1 *protocol.CreateTopicRequest, arg2 ...grpc.CallOption) (*protocol.CreateTopicResponse, error)
CreateTopic mocks base method
func (*MockHaraqaClient) DeleteTopic ¶
func (m *MockHaraqaClient) DeleteTopic(arg0 context.Context, arg1 *protocol.DeleteTopicRequest, arg2 ...grpc.CallOption) (*protocol.DeleteTopicResponse, error)
DeleteTopic mocks base method
func (*MockHaraqaClient) EXPECT ¶
func (m *MockHaraqaClient) EXPECT() *MockHaraqaClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHaraqaClient) ListTopics ¶
func (m *MockHaraqaClient) ListTopics(arg0 context.Context, arg1 *protocol.ListTopicsRequest, arg2 ...grpc.CallOption) (*protocol.ListTopicsResponse, error)
ListTopics mocks base method
func (*MockHaraqaClient) Lock ¶
func (m *MockHaraqaClient) Lock(arg0 context.Context, arg1 ...grpc.CallOption) (protocol.Haraqa_LockClient, error)
Lock mocks base method
func (*MockHaraqaClient) Offsets ¶
func (m *MockHaraqaClient) Offsets(arg0 context.Context, arg1 *protocol.OffsetRequest, arg2 ...grpc.CallOption) (*protocol.OffsetResponse, error)
Offsets mocks base method
func (*MockHaraqaClient) TruncateTopic ¶
func (m *MockHaraqaClient) TruncateTopic(arg0 context.Context, arg1 *protocol.TruncateTopicRequest, arg2 ...grpc.CallOption) (*protocol.TruncateTopicResponse, error)
TruncateTopic mocks base method
func (*MockHaraqaClient) WatchTopics ¶
func (m *MockHaraqaClient) WatchTopics(arg0 context.Context, arg1 ...grpc.CallOption) (protocol.Haraqa_WatchTopicsClient, error)
WatchTopics mocks base method
type MockHaraqaClientMockRecorder ¶
type MockHaraqaClientMockRecorder struct {
// contains filtered or unexported fields
}
MockHaraqaClientMockRecorder is the mock recorder for MockHaraqaClient
func (*MockHaraqaClientMockRecorder) CreateTopic ¶
func (mr *MockHaraqaClientMockRecorder) CreateTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateTopic indicates an expected call of CreateTopic
func (*MockHaraqaClientMockRecorder) DeleteTopic ¶
func (mr *MockHaraqaClientMockRecorder) DeleteTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteTopic indicates an expected call of DeleteTopic
func (*MockHaraqaClientMockRecorder) ListTopics ¶
func (mr *MockHaraqaClientMockRecorder) ListTopics(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListTopics indicates an expected call of ListTopics
func (*MockHaraqaClientMockRecorder) Lock ¶
func (mr *MockHaraqaClientMockRecorder) Lock(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Lock indicates an expected call of Lock
func (*MockHaraqaClientMockRecorder) Offsets ¶
func (mr *MockHaraqaClientMockRecorder) Offsets(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Offsets indicates an expected call of Offsets
func (*MockHaraqaClientMockRecorder) TruncateTopic ¶
func (mr *MockHaraqaClientMockRecorder) TruncateTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
TruncateTopic indicates an expected call of TruncateTopic
func (*MockHaraqaClientMockRecorder) WatchTopics ¶
func (mr *MockHaraqaClientMockRecorder) WatchTopics(arg0 interface{}, arg1 ...interface{}) *gomock.Call
WatchTopics indicates an expected call of WatchTopics
type MockHaraqa_LockClient ¶
type MockHaraqa_LockClient struct {
// contains filtered or unexported fields
}
MockHaraqa_LockClient is a mock of Haraqa_LockClient interface
func NewMockHaraqa_LockClient ¶
func NewMockHaraqa_LockClient(ctrl *gomock.Controller) *MockHaraqa_LockClient
NewMockHaraqa_LockClient creates a new mock instance
func (*MockHaraqa_LockClient) CloseSend ¶
func (m *MockHaraqa_LockClient) CloseSend() error
CloseSend mocks base method
func (*MockHaraqa_LockClient) Context ¶
func (m *MockHaraqa_LockClient) Context() context.Context
Context mocks base method
func (*MockHaraqa_LockClient) EXPECT ¶
func (m *MockHaraqa_LockClient) EXPECT() *MockHaraqa_LockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHaraqa_LockClient) Header ¶
func (m *MockHaraqa_LockClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockHaraqa_LockClient) Recv ¶
func (m *MockHaraqa_LockClient) Recv() (*protocol.LockResponse, error)
Recv mocks base method
func (*MockHaraqa_LockClient) RecvMsg ¶
func (m *MockHaraqa_LockClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockHaraqa_LockClient) Send ¶
func (m *MockHaraqa_LockClient) Send(arg0 *protocol.LockRequest) error
Send mocks base method
func (*MockHaraqa_LockClient) SendMsg ¶
func (m *MockHaraqa_LockClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockHaraqa_LockClient) Trailer ¶
func (m *MockHaraqa_LockClient) Trailer() metadata.MD
Trailer mocks base method
type MockHaraqa_LockClientMockRecorder ¶
type MockHaraqa_LockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockHaraqa_LockClientMockRecorder is the mock recorder for MockHaraqa_LockClient
func (*MockHaraqa_LockClientMockRecorder) CloseSend ¶
func (mr *MockHaraqa_LockClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockHaraqa_LockClientMockRecorder) Context ¶
func (mr *MockHaraqa_LockClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockHaraqa_LockClientMockRecorder) Header ¶
func (mr *MockHaraqa_LockClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockHaraqa_LockClientMockRecorder) Recv ¶
func (mr *MockHaraqa_LockClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockHaraqa_LockClientMockRecorder) RecvMsg ¶
func (mr *MockHaraqa_LockClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockHaraqa_LockClientMockRecorder) Send ¶
func (mr *MockHaraqa_LockClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockHaraqa_LockClientMockRecorder) SendMsg ¶
func (mr *MockHaraqa_LockClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockHaraqa_LockClientMockRecorder) Trailer ¶
func (mr *MockHaraqa_LockClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer
type MockHaraqa_LockServer ¶
type MockHaraqa_LockServer struct {
// contains filtered or unexported fields
}
MockHaraqa_LockServer is a mock of Haraqa_LockServer interface
func NewMockHaraqa_LockServer ¶
func NewMockHaraqa_LockServer(ctrl *gomock.Controller) *MockHaraqa_LockServer
NewMockHaraqa_LockServer creates a new mock instance
func (*MockHaraqa_LockServer) Context ¶
func (m *MockHaraqa_LockServer) Context() context.Context
Context mocks base method
func (*MockHaraqa_LockServer) EXPECT ¶
func (m *MockHaraqa_LockServer) EXPECT() *MockHaraqa_LockServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHaraqa_LockServer) Recv ¶
func (m *MockHaraqa_LockServer) Recv() (*protocol.LockRequest, error)
Recv mocks base method
func (*MockHaraqa_LockServer) RecvMsg ¶
func (m *MockHaraqa_LockServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockHaraqa_LockServer) Send ¶
func (m *MockHaraqa_LockServer) Send(arg0 *protocol.LockResponse) error
Send mocks base method
func (*MockHaraqa_LockServer) SendHeader ¶
func (m *MockHaraqa_LockServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method
func (*MockHaraqa_LockServer) SendMsg ¶
func (m *MockHaraqa_LockServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockHaraqa_LockServer) SetHeader ¶
func (m *MockHaraqa_LockServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method
func (*MockHaraqa_LockServer) SetTrailer ¶
func (m *MockHaraqa_LockServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method
type MockHaraqa_LockServerMockRecorder ¶
type MockHaraqa_LockServerMockRecorder struct {
// contains filtered or unexported fields
}
MockHaraqa_LockServerMockRecorder is the mock recorder for MockHaraqa_LockServer
func (*MockHaraqa_LockServerMockRecorder) Context ¶
func (mr *MockHaraqa_LockServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockHaraqa_LockServerMockRecorder) Recv ¶
func (mr *MockHaraqa_LockServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockHaraqa_LockServerMockRecorder) RecvMsg ¶
func (mr *MockHaraqa_LockServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockHaraqa_LockServerMockRecorder) Send ¶
func (mr *MockHaraqa_LockServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockHaraqa_LockServerMockRecorder) SendHeader ¶
func (mr *MockHaraqa_LockServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockHaraqa_LockServerMockRecorder) SendMsg ¶
func (mr *MockHaraqa_LockServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockHaraqa_LockServerMockRecorder) SetHeader ¶
func (mr *MockHaraqa_LockServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockHaraqa_LockServerMockRecorder) SetTrailer ¶
func (mr *MockHaraqa_LockServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockHaraqa_WatchTopicsClient ¶
type MockHaraqa_WatchTopicsClient struct {
// contains filtered or unexported fields
}
MockHaraqa_WatchTopicsClient is a mock of Haraqa_WatchTopicsClient interface
func NewMockHaraqa_WatchTopicsClient ¶
func NewMockHaraqa_WatchTopicsClient(ctrl *gomock.Controller) *MockHaraqa_WatchTopicsClient
NewMockHaraqa_WatchTopicsClient creates a new mock instance
func (*MockHaraqa_WatchTopicsClient) CloseSend ¶
func (m *MockHaraqa_WatchTopicsClient) CloseSend() error
CloseSend mocks base method
func (*MockHaraqa_WatchTopicsClient) Context ¶
func (m *MockHaraqa_WatchTopicsClient) Context() context.Context
Context mocks base method
func (*MockHaraqa_WatchTopicsClient) EXPECT ¶
func (m *MockHaraqa_WatchTopicsClient) EXPECT() *MockHaraqa_WatchTopicsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHaraqa_WatchTopicsClient) Header ¶
func (m *MockHaraqa_WatchTopicsClient) Header() (metadata.MD, error)
Header mocks base method
func (*MockHaraqa_WatchTopicsClient) Recv ¶
func (m *MockHaraqa_WatchTopicsClient) Recv() (*protocol.WatchResponse, error)
Recv mocks base method
func (*MockHaraqa_WatchTopicsClient) RecvMsg ¶
func (m *MockHaraqa_WatchTopicsClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockHaraqa_WatchTopicsClient) Send ¶
func (m *MockHaraqa_WatchTopicsClient) Send(arg0 *protocol.WatchRequest) error
Send mocks base method
func (*MockHaraqa_WatchTopicsClient) SendMsg ¶
func (m *MockHaraqa_WatchTopicsClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockHaraqa_WatchTopicsClient) Trailer ¶
func (m *MockHaraqa_WatchTopicsClient) Trailer() metadata.MD
Trailer mocks base method
type MockHaraqa_WatchTopicsClientMockRecorder ¶
type MockHaraqa_WatchTopicsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockHaraqa_WatchTopicsClientMockRecorder is the mock recorder for MockHaraqa_WatchTopicsClient
func (*MockHaraqa_WatchTopicsClientMockRecorder) CloseSend ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend
func (*MockHaraqa_WatchTopicsClientMockRecorder) Context ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockHaraqa_WatchTopicsClientMockRecorder) Header ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header
func (*MockHaraqa_WatchTopicsClientMockRecorder) Recv ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockHaraqa_WatchTopicsClientMockRecorder) RecvMsg ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockHaraqa_WatchTopicsClientMockRecorder) Send ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockHaraqa_WatchTopicsClientMockRecorder) SendMsg ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockHaraqa_WatchTopicsClientMockRecorder) Trailer ¶
func (mr *MockHaraqa_WatchTopicsClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer
type MockHaraqa_WatchTopicsServer ¶
type MockHaraqa_WatchTopicsServer struct {
// contains filtered or unexported fields
}
MockHaraqa_WatchTopicsServer is a mock of Haraqa_WatchTopicsServer interface
func NewMockHaraqa_WatchTopicsServer ¶
func NewMockHaraqa_WatchTopicsServer(ctrl *gomock.Controller) *MockHaraqa_WatchTopicsServer
NewMockHaraqa_WatchTopicsServer creates a new mock instance
func (*MockHaraqa_WatchTopicsServer) Context ¶
func (m *MockHaraqa_WatchTopicsServer) Context() context.Context
Context mocks base method
func (*MockHaraqa_WatchTopicsServer) EXPECT ¶
func (m *MockHaraqa_WatchTopicsServer) EXPECT() *MockHaraqa_WatchTopicsServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHaraqa_WatchTopicsServer) Recv ¶
func (m *MockHaraqa_WatchTopicsServer) Recv() (*protocol.WatchRequest, error)
Recv mocks base method
func (*MockHaraqa_WatchTopicsServer) RecvMsg ¶
func (m *MockHaraqa_WatchTopicsServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockHaraqa_WatchTopicsServer) Send ¶
func (m *MockHaraqa_WatchTopicsServer) Send(arg0 *protocol.WatchResponse) error
Send mocks base method
func (*MockHaraqa_WatchTopicsServer) SendHeader ¶
func (m *MockHaraqa_WatchTopicsServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method
func (*MockHaraqa_WatchTopicsServer) SendMsg ¶
func (m *MockHaraqa_WatchTopicsServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method
func (*MockHaraqa_WatchTopicsServer) SetHeader ¶
func (m *MockHaraqa_WatchTopicsServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method
func (*MockHaraqa_WatchTopicsServer) SetTrailer ¶
func (m *MockHaraqa_WatchTopicsServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method
type MockHaraqa_WatchTopicsServerMockRecorder ¶
type MockHaraqa_WatchTopicsServerMockRecorder struct {
// contains filtered or unexported fields
}
MockHaraqa_WatchTopicsServerMockRecorder is the mock recorder for MockHaraqa_WatchTopicsServer
func (*MockHaraqa_WatchTopicsServerMockRecorder) Context ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context
func (*MockHaraqa_WatchTopicsServerMockRecorder) Recv ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv
func (*MockHaraqa_WatchTopicsServerMockRecorder) RecvMsg ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockHaraqa_WatchTopicsServerMockRecorder) Send ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockHaraqa_WatchTopicsServerMockRecorder) SendHeader ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader
func (*MockHaraqa_WatchTopicsServerMockRecorder) SendMsg ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg
func (*MockHaraqa_WatchTopicsServerMockRecorder) SetHeader ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader
func (*MockHaraqa_WatchTopicsServerMockRecorder) SetTrailer ¶
func (mr *MockHaraqa_WatchTopicsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer
type MockReadWriteCloser ¶
type MockReadWriteCloser struct {
// contains filtered or unexported fields
}
MockReadWriteCloser is a mock of ReadWriteCloser interface
func NewMockReadWriteCloser ¶
func NewMockReadWriteCloser(ctrl *gomock.Controller) *MockReadWriteCloser
NewMockReadWriteCloser creates a new mock instance
func (*MockReadWriteCloser) Close ¶
func (m *MockReadWriteCloser) Close() error
Close mocks base method
func (*MockReadWriteCloser) EXPECT ¶
func (m *MockReadWriteCloser) EXPECT() *MockReadWriteCloserMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockReadWriteCloserMockRecorder ¶
type MockReadWriteCloserMockRecorder struct {
// contains filtered or unexported fields
}
MockReadWriteCloserMockRecorder is the mock recorder for MockReadWriteCloser
func (*MockReadWriteCloserMockRecorder) Close ¶
func (mr *MockReadWriteCloserMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockReadWriteCloserMockRecorder) Read ¶
func (mr *MockReadWriteCloserMockRecorder) Read(arg0 interface{}) *gomock.Call
Read indicates an expected call of Read
func (*MockReadWriteCloserMockRecorder) Write ¶
func (mr *MockReadWriteCloserMockRecorder) Write(arg0 interface{}) *gomock.Call
Write indicates an expected call of Write