rabbitmq

Documentation

Overview

Package rabbitmq is a generated GoMock package.

Package rabbitmq is a generated GoMock package.

Index

• type ConsumerRepository
• type ConsumerRoutes
  • func NewConsumerRoutes(conn *mrabbitmq.RabbitMQConnection, logger mlog.Logger, ...) *ConsumerRoutes
  • func (cr *ConsumerRoutes) Register(queueName string, handler QueueHandlerFunc)
  • func (cr *ConsumerRoutes) RunConsumers() error
• type MockConsumerRepository
  • func NewMockConsumerRepository(ctrl *gomock.Controller) *MockConsumerRepository
  • func (m *MockConsumerRepository) EXPECT() *MockConsumerRepositoryMockRecorder
  • func (m *MockConsumerRepository) Register(arg0 string, arg1 QueueHandlerFunc)
  • func (m *MockConsumerRepository) RunConsumers() error
• type MockConsumerRepositoryMockRecorder
  • func (mr *MockConsumerRepositoryMockRecorder) Register(arg0, arg1 any) *gomock.Call
  • func (mr *MockConsumerRepositoryMockRecorder) RunConsumers() *gomock.Call
• type MockProducerRepository
  • func NewMockProducerRepository(ctrl *gomock.Controller) *MockProducerRepository
  • func (m *MockProducerRepository) EXPECT() *MockProducerRepositoryMockRecorder
  • func (m *MockProducerRepository) ProducerDefault(arg0 context.Context, arg1, arg2 string, arg3 mmodel.Queue) (*string, error)
• type MockProducerRepositoryMockRecorder
  • func (mr *MockProducerRepositoryMockRecorder) ProducerDefault(arg0, arg1, arg2, arg3 any) *gomock.Call
• type ProducerRabbitMQRepository
  • func NewProducerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ProducerRabbitMQRepository
  • func (prmq *ProducerRabbitMQRepository) ProducerDefault(ctx context.Context, exchange, key string, queueMessage mmodel.Queue) (*string, error)
• type ProducerRepository
• type QueueHandlerFunc

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.

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) 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(arg0 context.Context, arg1, arg2 string, arg3 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) ProducerDefault

func (mr *MockProducerRepositoryMockRecorder) ProducerDefault(arg0, arg1, arg2, arg3 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 *mrabbitmq.RabbitMQConnection) *ProducerRabbitMQRepository

NewProducerRabbitMQ returns a new instance of ProducerRabbitMQRepository using the given rabbitmq connection.

func (*ProducerRabbitMQRepository) ProducerDefault

func (prmq *ProducerRabbitMQRepository) ProducerDefault(ctx context.Context, exchange, key string, queueMessage mmodel.Queue) (*string, error)

type ProducerRepository

type ProducerRepository interface {
	ProducerDefault(ctx context.Context, exchange, key string, message mmodel.Queue) (*string, error)
}

ProducerRepository provides an interface for Producer related to rabbitmq.

type QueueHandlerFunc

type QueueHandlerFunc func(ctx context.Context, body []byte) error

QueueHandlerFunc is a function that process a specific queue.