logmq

Documentation

Index

• func NewMessageHandler(logger *logging.Logger, batcher batcher) consumer.MessageHandler
• func WithQueue(queueConfig *mqs.QueueConfig) func(opts *LogMQOption)
• type LogInfra
• type LogMQ
  • func New(opts ...func(opts *LogMQOption)) *LogMQ
  • func (q *LogMQ) Init(ctx context.Context) (func(), error)
  • func (q *LogMQ) Publish(ctx context.Context, event models.DeliveryEvent) error
  • func (q *LogMQ) Subscribe(ctx context.Context) (mqs.Subscription, error)
• type LogMQOption

Functions

func NewMessageHandler

func NewMessageHandler(logger *logging.Logger, batcher batcher) consumer.MessageHandler

func WithQueue

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

Types

type LogInfra

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

type LogMQ

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

func New

func New(opts ...func(opts *LogMQOption)) *LogMQ

func (*LogMQ) Init

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

func (*LogMQ) Publish

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

func (*LogMQ) Subscribe

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

type LogMQOption

type LogMQOption struct {
	QueueConfig *mqs.QueueConfig
}