Documentation
¶
Overview ¶
Package mock_messaging is a generated GoMock package.
Package mock_messaging is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMessageConsumer ¶
type MockMessageConsumer struct {
// contains filtered or unexported fields
}
MockMessageConsumer is a mock of MessageConsumer interface.
func NewMockMessageConsumer ¶
func NewMockMessageConsumer(ctrl *gomock.Controller) *MockMessageConsumer
NewMockMessageConsumer creates a new mock instance.
func (*MockMessageConsumer) Connect ¶
func (m *MockMessageConsumer) Connect(topic string) error
Connect mocks base method.
func (*MockMessageConsumer) Consume ¶
func (m *MockMessageConsumer) Consume(ctx context.Context) (messaging.Message, messaging.MessageProcessedCallback, messaging.MessageFailedCallback, error)
Consume mocks base method.
func (*MockMessageConsumer) EXPECT ¶
func (m *MockMessageConsumer) EXPECT() *MockMessageConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMessageConsumerMockRecorder ¶
type MockMessageConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageConsumerMockRecorder is the mock recorder for MockMessageConsumer.
func (*MockMessageConsumerMockRecorder) Close ¶
func (mr *MockMessageConsumerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockMessageConsumerMockRecorder) Connect ¶
func (mr *MockMessageConsumerMockRecorder) Connect(topic interface{}) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockMessageConsumerMockRecorder) Consume ¶
func (mr *MockMessageConsumerMockRecorder) Consume(ctx interface{}) *gomock.Call
Consume indicates an expected call of Consume.
type MockMessageProducer ¶
type MockMessageProducer struct {
// contains filtered or unexported fields
}
MockMessageProducer is a mock of MessageProducer interface.
func NewMockMessageProducer ¶
func NewMockMessageProducer(ctrl *gomock.Controller) *MockMessageProducer
NewMockMessageProducer creates a new mock instance.
func (*MockMessageProducer) Connect ¶
func (m *MockMessageProducer) Connect(topic string) error
Connect mocks base method.
func (*MockMessageProducer) EXPECT ¶
func (m *MockMessageProducer) EXPECT() *MockMessageProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMessageProducerMockRecorder ¶
type MockMessageProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageProducerMockRecorder is the mock recorder for MockMessageProducer.
func (*MockMessageProducerMockRecorder) Close ¶
func (mr *MockMessageProducerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockMessageProducerMockRecorder) Connect ¶
func (mr *MockMessageProducerMockRecorder) Connect(topic interface{}) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockMessageProducerMockRecorder) Produce ¶
func (mr *MockMessageProducerMockRecorder) Produce(ctx, key, data interface{}) *gomock.Call
Produce indicates an expected call of Produce.
Source Files