rabbitmq

Documentation

Overview

Package rabbitmq is a generated GoMock package.

Package rabbitmq is a generated GoMock package.

Index

• type ConsumerRabbitMQRepository
  • func NewConsumerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ConsumerRabbitMQRepository
  • func (crmq *ConsumerRabbitMQRepository) ConsumerDefault(response chan string)
• type ConsumerRepository
• type MockConsumerRepository
  • func NewMockConsumerRepository(ctrl *gomock.Controller) *MockConsumerRepository
  • func (m *MockConsumerRepository) ConsumerDefault(arg0 chan string)
  • func (m *MockConsumerRepository) EXPECT() *MockConsumerRepositoryMockRecorder
• type MockConsumerRepositoryMockRecorder
  • func (mr *MockConsumerRepositoryMockRecorder) ConsumerDefault(arg0 any) *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

Types

type ConsumerRabbitMQRepository

type ConsumerRabbitMQRepository struct {
	// contains filtered or unexported fields
}

ConsumerRabbitMQRepository is a rabbitmq implementation of the consumer

func NewConsumerRabbitMQ

func NewConsumerRabbitMQ(c *mrabbitmq.RabbitMQConnection) *ConsumerRabbitMQRepository

NewConsumerRabbitMQ returns a new instance of ConsumerRabbitMQRepository using the given rabbitmq connection.

func (*ConsumerRabbitMQRepository) ConsumerDefault

func (crmq *ConsumerRabbitMQRepository) ConsumerDefault(response chan string)

type ConsumerRepository

type ConsumerRepository interface {
	ConsumerDefault(message chan string)
}

ConsumerRepository provides an interface for Consumer related to rabbitmq.

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) ConsumerDefault

func (m *MockConsumerRepository) ConsumerDefault(arg0 chan string)

ConsumerDefault mocks base method.

func (*MockConsumerRepository) EXPECT

func (m *MockConsumerRepository) EXPECT() *MockConsumerRepositoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockConsumerRepositoryMockRecorder

type MockConsumerRepositoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerRepositoryMockRecorder is the mock recorder for MockConsumerRepository.

func (*MockConsumerRepositoryMockRecorder) ConsumerDefault

func (mr *MockConsumerRepositoryMockRecorder) ConsumerDefault(arg0 any) *gomock.Call

ConsumerDefault indicates an expected call of ConsumerDefault.

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.