postgres

Documentation

Index

• type MessageQueueImplOpt
  • func WithLogger(l *zerolog.Logger) MessageQueueImplOpt
  • func WithQos(qos int) MessageQueueImplOpt
• type MessageQueueImplOpts
• type PostgresMessageQueue
  • 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)

Types

type MessageQueueImplOpt

type MessageQueueImplOpt func(*MessageQueueImplOpts)

func WithLogger

func WithLogger(l *zerolog.Logger) MessageQueueImplOpt

func WithQos

func WithQos(qos int) MessageQueueImplOpt

type MessageQueueImplOpts

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

type PostgresMessageQueue

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

func NewPostgresMQ

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

func (*PostgresMessageQueue) AddMessage

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

func (*PostgresMessageQueue) Clone

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

func (*PostgresMessageQueue) IsReady

func (p *PostgresMessageQueue) IsReady() bool

func (*PostgresMessageQueue) RegisterTenant

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

func (*PostgresMessageQueue) SetQOS

func (p *PostgresMessageQueue) SetQOS(prefetchCount int)

func (*PostgresMessageQueue) Subscribe

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