logmq

package

v0.6.1 Latest Latest Go to latest Published: Oct 6, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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

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

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 struct {
	QueueConfig *mqs.QueueConfig
}