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 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
- type MockHeartbeatServiceServer
- type MockHeartbeatServiceServerMockRecorder
- type MockPublisherServiceServer
- func (m *MockPublisherServiceServer) BatchPublish(arg0 context.Context, arg1 *pb.BatchMessage) (*pb.Response, error)
- func (m *MockPublisherServiceServer) EXPECT() *MockPublisherServiceServerMockRecorder
- func (m *MockPublisherServiceServer) Publish(arg0 context.Context, arg1 *pb.SimpleMessage) (*pb.Response, error)
- func (m *MockPublisherServiceServer) RequestReply(arg0 context.Context, arg1 *pb.SimpleMessage) (*pb.SimpleMessage, error)
- type MockPublisherServiceServerMockRecorder
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.
type MockHeartbeatServiceServer ¶
type MockHeartbeatServiceServer struct {
// contains filtered or unexported fields
}
MockHeartbeatServiceServer is a mock of HeartbeatServiceServer interface.
func NewMockHeartbeatServiceServer ¶
func NewMockHeartbeatServiceServer(ctrl *gomock.Controller) *MockHeartbeatServiceServer
NewMockHeartbeatServiceServer creates a new mock instance.
func (*MockHeartbeatServiceServer) EXPECT ¶
func (m *MockHeartbeatServiceServer) EXPECT() *MockHeartbeatServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockHeartbeatServiceServerMockRecorder ¶
type MockHeartbeatServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockHeartbeatServiceServerMockRecorder is the mock recorder for MockHeartbeatServiceServer.
func (*MockHeartbeatServiceServerMockRecorder) Heartbeat ¶
func (mr *MockHeartbeatServiceServerMockRecorder) Heartbeat(arg0, arg1 interface{}) *gomock.Call
Heartbeat indicates an expected call of Heartbeat.
type MockPublisherServiceServer ¶
type MockPublisherServiceServer struct {
// contains filtered or unexported fields
}
MockPublisherServiceServer is a mock of PublisherServiceServer interface.
func NewMockPublisherServiceServer ¶
func NewMockPublisherServiceServer(ctrl *gomock.Controller) *MockPublisherServiceServer
NewMockPublisherServiceServer creates a new mock instance.
func (*MockPublisherServiceServer) BatchPublish ¶
func (m *MockPublisherServiceServer) BatchPublish(arg0 context.Context, arg1 *pb.BatchMessage) (*pb.Response, error)
BatchPublish mocks base method.
func (*MockPublisherServiceServer) EXPECT ¶
func (m *MockPublisherServiceServer) EXPECT() *MockPublisherServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPublisherServiceServer) Publish ¶
func (m *MockPublisherServiceServer) Publish(arg0 context.Context, arg1 *pb.SimpleMessage) (*pb.Response, error)
Publish mocks base method.
func (*MockPublisherServiceServer) RequestReply ¶
func (m *MockPublisherServiceServer) RequestReply(arg0 context.Context, arg1 *pb.SimpleMessage) (*pb.SimpleMessage, error)
RequestReply mocks base method.
type MockPublisherServiceServerMockRecorder ¶
type MockPublisherServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherServiceServerMockRecorder is the mock recorder for MockPublisherServiceServer.
func (*MockPublisherServiceServerMockRecorder) BatchPublish ¶
func (mr *MockPublisherServiceServerMockRecorder) BatchPublish(arg0, arg1 interface{}) *gomock.Call
BatchPublish indicates an expected call of BatchPublish.
func (*MockPublisherServiceServerMockRecorder) Publish ¶
func (mr *MockPublisherServiceServerMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockPublisherServiceServerMockRecorder) RequestReply ¶
func (mr *MockPublisherServiceServerMockRecorder) RequestReply(arg0, arg1 interface{}) *gomock.Call
RequestReply indicates an expected call of RequestReply.
Source Files