Affected by 
Documentation
¶
Index ¶
- type MessageQueueImplOpt
- type MessageQueueImplOpts
- type PostgresMessageQueue
- func (p *PostgresMessageQueue) Clone() (func() error, msgqueue.MessageQueue, error)
- func (p *PostgresMessageQueue) IsReady() bool
- func (p *PostgresMessageQueue) RegisterTenant(ctx context.Context, tenantId string) error
- func (p *PostgresMessageQueue) SendMessage(ctx context.Context, queue msgqueue.Queue, task *msgqueue.Message) error
- func (p *PostgresMessageQueue) SetQOS(prefetchCount int)
- func (p *PostgresMessageQueue) Subscribe(queue msgqueue.Queue, preAck msgqueue.AckHook, postAck msgqueue.AckHook) (func() error, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 v1.MessageQueueRepository, fs ...MessageQueueImplOpt) (func() error, *PostgresMessageQueue, error)
func (*PostgresMessageQueue) Clone ¶
func (p *PostgresMessageQueue) Clone() (func() error, msgqueue.MessageQueue, error)
func (*PostgresMessageQueue) IsReady ¶
func (p *PostgresMessageQueue) IsReady() bool
func (*PostgresMessageQueue) RegisterTenant ¶
func (p *PostgresMessageQueue) RegisterTenant(ctx context.Context, tenantId string) error
func (*PostgresMessageQueue) SendMessage ¶ added in v0.74.3
func (*PostgresMessageQueue) SetQOS ¶
func (p *PostgresMessageQueue) SetQOS(prefetchCount int)
Source Files
Click to show internal directories.
Click to hide internal directories.