Documentation
¶
Overview ¶
Package rabbitmq is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerRepository ¶
type ConsumerRepository interface {
Register(queueName string, handler QueueHandlerFunc)
RunConsumers() error
}
ConsumerRepository provides an interface for Consumer related to rabbitmq.
type ConsumerRoutes ¶
type ConsumerRoutes struct {
mlog.Logger
mopentelemetry.Telemetry
// contains filtered or unexported fields
}
ConsumerRoutes struct
func NewConsumerRoutes ¶
func NewConsumerRoutes(conn *mrabbitmq.RabbitMQConnection, logger mlog.Logger, telemetry *mopentelemetry.Telemetry) *ConsumerRoutes
NewConsumerRoutes creates a new instance of ConsumerRoutes.
func (*ConsumerRoutes) Register ¶
func (cr *ConsumerRoutes) Register(queueName string, handler QueueHandlerFunc)
Register add a new queue to handler.
func (*ConsumerRoutes) RunConsumers ¶
func (cr *ConsumerRoutes) RunConsumers() error
RunConsumers init consume for all registry queues.
type MockConsumerRepository ¶
type MockConsumerRepository struct {
// contains filtered or unexported fields
}
MockConsumerRepository is a mock of ConsumerRepository interface.
func NewMockConsumerRepository ¶
func NewMockConsumerRepository(ctrl *gomock.Controller) *MockConsumerRepository
NewMockConsumerRepository creates a new mock instance.
func (*MockConsumerRepository) EXPECT ¶
func (m *MockConsumerRepository) EXPECT() *MockConsumerRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConsumerRepository) Register ¶
func (m *MockConsumerRepository) Register(arg0 string, arg1 QueueHandlerFunc)
Register mocks base method.
func (*MockConsumerRepository) RunConsumers ¶
func (m *MockConsumerRepository) RunConsumers() error
RunConsumers mocks base method.
type MockConsumerRepositoryMockRecorder ¶
type MockConsumerRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerRepositoryMockRecorder is the mock recorder for MockConsumerRepository.
func (*MockConsumerRepositoryMockRecorder) Register ¶
func (mr *MockConsumerRepositoryMockRecorder) Register(arg0, arg1 any) *gomock.Call
Register indicates an expected call of Register.
func (*MockConsumerRepositoryMockRecorder) RunConsumers ¶
func (mr *MockConsumerRepositoryMockRecorder) RunConsumers() *gomock.Call
RunConsumers indicates an expected call of RunConsumers.
Source Files