publishmq

Documentation

Index

• Variables
• func NewMessageHandler(eventHandler EventHandler) consumer.MessageHandler
• func WithQueue(queueConfig *mqs.QueueConfig) func(opts *PublishMQOption)
• type EventHandler
  • func NewEventHandler(logger *otelzap.Logger, redisClient *redis.Client, ...) EventHandler
• type PublishMQ
  • func New(opts ...func(opts *PublishMQOption)) *PublishMQ
  • func (q *PublishMQ) Subscribe(ctx context.Context) (mqs.Subscription, error)
• type PublishMQOption

Variables

var (
	ErrInvalidTopic = errors.New("invalid topic")
)

Functions

func NewMessageHandler

func NewMessageHandler(eventHandler EventHandler) consumer.MessageHandler

func WithQueue

func WithQueue(queueConfig *mqs.QueueConfig) func(opts *PublishMQOption)

Types

type EventHandler

type EventHandler interface {
	Handle(ctx context.Context, event *models.Event) error
}

func NewEventHandler

func NewEventHandler(
	logger *otelzap.Logger,
	redisClient *redis.Client,
	deliveryMQ *deliverymq.DeliveryMQ,
	entityStore models.EntityStore,
	eventTracer eventtracer.EventTracer,
	topics []string,
) EventHandler

type PublishMQ

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

func New

func New(opts ...func(opts *PublishMQOption)) *PublishMQ

func (*PublishMQ) Subscribe

func (q *PublishMQ) Subscribe(ctx context.Context) (mqs.Subscription, error)

type PublishMQOption

type PublishMQOption struct {
	QueueConfig *mqs.QueueConfig
}