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 MockProducerRepository ¶
type MockProducerRepository struct {
// contains filtered or unexported fields
}
MockProducerRepository is a mock of ProducerRepository interface.
func NewMockProducerRepository ¶
func NewMockProducerRepository(ctrl *gomock.Controller) *MockProducerRepository
NewMockProducerRepository creates a new mock instance.
func (*MockProducerRepository) CheckRabbitMQHealth ¶
func (m *MockProducerRepository) CheckRabbitMQHealth() bool
CheckRabbitMQHealth mocks base method.
func (*MockProducerRepository) EXPECT ¶
func (m *MockProducerRepository) EXPECT() *MockProducerRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProducerRepository) ProducerDefault ¶
func (m *MockProducerRepository) ProducerDefault(ctx context.Context, exchange, key string, message mmodel.Queue) (*string, error)
ProducerDefault mocks base method.
type MockProducerRepositoryMockRecorder ¶
type MockProducerRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerRepositoryMockRecorder is the mock recorder for MockProducerRepository.
func (*MockProducerRepositoryMockRecorder) CheckRabbitMQHealth ¶
func (mr *MockProducerRepositoryMockRecorder) CheckRabbitMQHealth() *gomock.Call
CheckRabbitMQHealth indicates an expected call of CheckRabbitMQHealth.
func (*MockProducerRepositoryMockRecorder) ProducerDefault ¶
func (mr *MockProducerRepositoryMockRecorder) ProducerDefault(ctx, exchange, key, message any) *gomock.Call
ProducerDefault indicates an expected call of ProducerDefault.
type ProducerRabbitMQRepository ¶
type ProducerRabbitMQRepository struct {
// contains filtered or unexported fields
}
ProducerRabbitMQRepository is a rabbitmq implementation of the producer
func NewProducerRabbitMQ ¶
func NewProducerRabbitMQ(c *libRabbitmq.RabbitMQConnection) *ProducerRabbitMQRepository
NewProducerRabbitMQ returns a new instance of ProducerRabbitMQRepository using the given rabbitmq connection.
func (*ProducerRabbitMQRepository) CheckRabbitMQHealth ¶
func (prmq *ProducerRabbitMQRepository) CheckRabbitMQHealth() bool
CheckRabbitMQHealth checks the health of the rabbitmq connection.
func (*ProducerRabbitMQRepository) ProducerDefault ¶
type ProducerRepository ¶
type ProducerRepository interface {
ProducerDefault(ctx context.Context, exchange, key string, message mmodel.Queue) (*string, error)
CheckRabbitMQHealth() bool
}
ProducerRepository provides an interface for Producer related to rabbitmq. It is used to send messages to a queue.
Source Files