Documentation ¶
Index ¶
- type MockConsumerServiceServer
- func (m *MockConsumerServiceServer) EXPECT() *MockConsumerServiceServerMockRecorder
- func (m *MockConsumerServiceServer) Subscribe(arg0 context.Context, arg1 *pb.Subscription) (*pb.Response, error)
- func (m *MockConsumerServiceServer) SubscribeStream(arg0 pb.ConsumerService_SubscribeStreamServer) error
- func (m *MockConsumerServiceServer) Unsubscribe(arg0 context.Context, arg1 *pb.Subscription) (*pb.Response, error)
- type MockConsumerServiceServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumerServiceServer ¶
type MockConsumerServiceServer struct {
// contains filtered or unexported fields
}
MockConsumerServiceServer is a mock of ConsumerServiceServer interface.
func NewMockConsumerServiceServer ¶
func NewMockConsumerServiceServer(ctrl *gomock.Controller) *MockConsumerServiceServer
NewMockConsumerServiceServer creates a new mock instance.
func (*MockConsumerServiceServer) EXPECT ¶
func (m *MockConsumerServiceServer) EXPECT() *MockConsumerServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConsumerServiceServer) Subscribe ¶
func (m *MockConsumerServiceServer) Subscribe(arg0 context.Context, arg1 *pb.Subscription) (*pb.Response, error)
Subscribe mocks base method.
func (*MockConsumerServiceServer) SubscribeStream ¶
func (m *MockConsumerServiceServer) SubscribeStream(arg0 pb.ConsumerService_SubscribeStreamServer) error
SubscribeStream mocks base method.
func (*MockConsumerServiceServer) Unsubscribe ¶
func (m *MockConsumerServiceServer) Unsubscribe(arg0 context.Context, arg1 *pb.Subscription) (*pb.Response, error)
Unsubscribe mocks base method.
type MockConsumerServiceServerMockRecorder ¶
type MockConsumerServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerServiceServerMockRecorder is the mock recorder for MockConsumerServiceServer.
func (*MockConsumerServiceServerMockRecorder) Subscribe ¶
func (mr *MockConsumerServiceServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockConsumerServiceServerMockRecorder) SubscribeStream ¶
func (mr *MockConsumerServiceServerMockRecorder) SubscribeStream(arg0 interface{}) *gomock.Call
SubscribeStream indicates an expected call of SubscribeStream.
func (*MockConsumerServiceServerMockRecorder) Unsubscribe ¶
func (mr *MockConsumerServiceServerMockRecorder) Unsubscribe(arg0, arg1 interface{}) *gomock.Call
Unsubscribe indicates an expected call of Unsubscribe.
Click to show internal directories.
Click to hide internal directories.