deliverymq

Documentation

Index

• func NewMessageHandler(logger *otelzap.Logger, redisClient *redis.Client, logMQ *logmq.LogMQ, ...) consumer.MessageHandler
• func NewRetryScheduler(deliverymq *DeliveryMQ, redisConfig *redis.RedisConfig) scheduler.Scheduler
• func WithQueue(queueConfig *mqs.QueueConfig) func(opts *DeliveryMQOption)
• type DeliveryAWSInfra
  • func (i *DeliveryAWSInfra) DeclareInfrastructure(ctx context.Context) error
• type DeliveryInfra
  • func NewDeliveryAWSInfra(config *mqs.AWSSQSConfig) DeliveryInfra
  • func NewDeliveryRabbitMQInfra(config *mqs.RabbitMQConfig) DeliveryInfra
• type DeliveryMQ
  • func New(opts ...func(opts *DeliveryMQOption)) *DeliveryMQ
  • func (q *DeliveryMQ) Init(ctx context.Context) (func(), error)
  • func (q *DeliveryMQ) Publish(ctx context.Context, event models.DeliveryEvent) error
  • func (q *DeliveryMQ) Subscribe(ctx context.Context) (mqs.Subscription, error)
• type DeliveryMQOption
• type DeliveryRabbitMQInfra
  • func (i *DeliveryRabbitMQInfra) DeclareInfrastructure(ctx context.Context) error
• type RetryMessage
  • func RetryMessageFromDeliveryEvent(deliveryEvent models.DeliveryEvent) RetryMessage
  • func (m *RetryMessage) FromString(str string) error
  • func (m *RetryMessage) ToDeliveryEvent() models.DeliveryEvent
  • func (m *RetryMessage) ToString() (string, error)

Functions

func NewMessageHandler

func NewMessageHandler(
	logger *otelzap.Logger,
	redisClient *redis.Client,
	logMQ *logmq.LogMQ,
	entityStore models.EntityStore,
	logStore models.LogStore,
	eventTracer eventtracer.EventTracer,
	retryScheduler scheduler.Scheduler,
	retryBackoff backoff.Backoff,
	retryMaxCount int,
) consumer.MessageHandler

func NewRetryScheduler

func NewRetryScheduler(deliverymq *DeliveryMQ, redisConfig *redis.RedisConfig) scheduler.Scheduler

func WithQueue

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

Types

type DeliveryAWSInfra

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

func (*DeliveryAWSInfra) DeclareInfrastructure

func (i *DeliveryAWSInfra) DeclareInfrastructure(ctx context.Context) error

type DeliveryInfra

type DeliveryInfra interface {
	DeclareInfrastructure(ctx context.Context) error
}

func NewDeliveryAWSInfra

func NewDeliveryAWSInfra(config *mqs.AWSSQSConfig) DeliveryInfra

func NewDeliveryRabbitMQInfra

func NewDeliveryRabbitMQInfra(config *mqs.RabbitMQConfig) DeliveryInfra

type DeliveryMQ

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

func New

func New(opts ...func(opts *DeliveryMQOption)) *DeliveryMQ

func (*DeliveryMQ) Init

func (q *DeliveryMQ) Init(ctx context.Context) (func(), error)

func (*DeliveryMQ) Publish

func (q *DeliveryMQ) Publish(ctx context.Context, event models.DeliveryEvent) error

func (*DeliveryMQ) Subscribe

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

type DeliveryMQOption

type DeliveryMQOption struct {
	QueueConfig *mqs.QueueConfig
}

type DeliveryRabbitMQInfra

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

func (*DeliveryRabbitMQInfra) DeclareInfrastructure

func (i *DeliveryRabbitMQInfra) DeclareInfrastructure(ctx context.Context) error

type RetryMessage

type RetryMessage struct {
	DeliveryEventID string
	EventID         string
	TenantID        string
	DestinationID   string
	Attempt         int
	Telemetry       *models.DeliveryEventTelemetry
}

func RetryMessageFromDeliveryEvent

func RetryMessageFromDeliveryEvent(deliveryEvent models.DeliveryEvent) RetryMessage

func (*RetryMessage) FromString

func (m *RetryMessage) FromString(str string) error

func (*RetryMessage) ToDeliveryEvent

func (m *RetryMessage) ToDeliveryEvent() models.DeliveryEvent

func (*RetryMessage) ToString

func (m *RetryMessage) ToString() (string, error)