postgres

Dec 18, 2024

Changes in this version

+ type MessageQueueImplOpt func(*MessageQueueImplOpts)

+ func WithLogger(l *zerolog.Logger) MessageQueueImplOpt

+ func WithQos(qos int) MessageQueueImplOpt

+ type MessageQueueImplOpts struct

+ type PostgresMessageQueue struct

+ func NewPostgresMQ(repo repository.MessageQueueRepository, fs ...MessageQueueImplOpt) *PostgresMessageQueue

+ func (p *PostgresMessageQueue) AddMessage(ctx context.Context, queue msgqueue.Queue, task *msgqueue.Message) error

+ func (p *PostgresMessageQueue) Clone() (func() error, msgqueue.MessageQueue)

+ func (p *PostgresMessageQueue) IsReady() bool

+ func (p *PostgresMessageQueue) RegisterTenant(ctx context.Context, tenantId string) error

+ func (p *PostgresMessageQueue) SetQOS(prefetchCount int)

+ func (p *PostgresMessageQueue) Subscribe(queue msgqueue.Queue, preAck msgqueue.AckHook, postAck msgqueue.AckHook) (func() error, error)