rabbitmq

Documentation

Index

• Constants
• Variables
• func NewRabbitMQPublisher(config *config.AppConfig, logger logger.Logger) pubsub.AMQPPublisher
• type Consumer
  • func NewRabbitMQConsumer(config *config.AppConfig, logger logger.Logger) Consumer
• type ConsumerManager
  • func NewConsumerManager(consumerRunners []ConsumerRunner) *ConsumerManager
  • func (c ConsumerManager) Run(ctx context.Context)
• type ConsumerRunner
  • func NewSimpleConsumerRunner(consumer Consumer) ConsumerRunner
• type ConsumerRunnerOptions
• type RabbitMQConsumer
  • func (c *RabbitMQConsumer) Consume(ctx context.Context, runner ConsumerRunner)
• type RabbitMQPublisher
  • func (r *RabbitMQPublisher) Publish(ctx context.Context, data any, routingKey string) error
• type SimpleConsumerRunner
  • func (s SimpleConsumerRunner) Do(ctx context.Context)
  • func (s SimpleConsumerRunner) Options() ConsumerRunnerOptions
  • func (s SimpleConsumerRunner) Run(ctx context.Context)

Constants

const DefaultExchange = "events"

Variables

var Module = fx.Options(
	consumers,
	consumerRunners,
	consumerManager,
	publishers,
)

Functions

func NewRabbitMQPublisher

func NewRabbitMQPublisher(config *config.AppConfig, logger logger.Logger) pubsub.AMQPPublisher

Types

type Consumer

type Consumer interface {
	Consume(ctx context.Context, runner ConsumerRunner)
}

func NewRabbitMQConsumer

func NewRabbitMQConsumer(config *config.AppConfig, logger logger.Logger) Consumer

type ConsumerManager

type ConsumerManager struct {
	ConsumerRunners []ConsumerRunner
}

func NewConsumerManager

func NewConsumerManager(consumerRunners []ConsumerRunner) *ConsumerManager

func (ConsumerManager) Run

func (c ConsumerManager) Run(ctx context.Context)

type ConsumerRunner

type ConsumerRunner interface {
	Run(ctx context.Context)
	Do(ctx context.Context)
	Options() ConsumerRunnerOptions
}

func NewSimpleConsumerRunner

func NewSimpleConsumerRunner(consumer Consumer) ConsumerRunner

type ConsumerRunnerOptions

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

type RabbitMQConsumer

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

func (*RabbitMQConsumer) Consume

func (c *RabbitMQConsumer) Consume(ctx context.Context, runner ConsumerRunner)

type RabbitMQPublisher

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

func (*RabbitMQPublisher) Publish

func (r *RabbitMQPublisher) Publish(ctx context.Context, data any, routingKey string) error

type SimpleConsumerRunner

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

func (SimpleConsumerRunner) Do

func (s SimpleConsumerRunner) Do(ctx context.Context)

func (SimpleConsumerRunner) Options

func (s SimpleConsumerRunner) Options() ConsumerRunnerOptions

func (SimpleConsumerRunner) Run

func (s SimpleConsumerRunner) Run(ctx context.Context)