publishmq

Documentation

Index

• Variables
• func NewMessageHandler(eventHandler EventHandler) consumer.MessageHandler
• func WithQueue(queueConfig *mqs.QueueConfig) func(opts *PublishMQOption)
• type EventHandler
  • func NewEventHandler(logger *logging.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
• type PublishedEvent

Variables

var (
	ErrInvalidTopic  = errors.New("invalid topic")
	ErrRequiredTopic = errors.New("topic is required")
)

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 *logging.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
}

type PublishedEvent

type PublishedEvent struct {
	ID               string                 `json:"id"`
	TenantID         string                 `json:"tenant_id" binding:"required"`
	DestinationID    string                 `json:"destination_id"`
	Topic            string                 `json:"topic"`
	EligibleForRetry *bool                  `json:"eligible_for_retry"`
	Time             time.Time              `json:"time"`
	Metadata         map[string]string      `json:"metadata"`
	Data             map[string]interface{} `json:"data"`
}