pgqueue

Documentation

Index

• func SetDefaultLogger() pgq.WorkerOption
• func SqlConnect(ctx context.Context, dbConnection string) (*sql.DB, *pgq.Worker, error)
• type CallbackWithContext
• type Consumer
  • func NewConsumer(db *sql.DB, queueName string, opts ...ConsumerOption) *Consumer
  • func (c *Consumer) Backlog(ctx context.Context) (int64, error)
  • func (c *Consumer) Pull(ctx context.Context, cb messaging.Callback) error
  • func (c *Consumer) Stop()
• type ConsumerOption
• type Publisher
  • func NewPublisher(w *pgq.Worker, queueName string, opts ...PublisherOption) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, data ...[]byte) error
• type PublisherOption
  • func WithJobRetryWaits(waits []time.Duration) PublisherOption
  • func WithMaxRetries(maxRetries int) PublisherOption

Functions

func SetDefaultLogger

func SetDefaultLogger() pgq.WorkerOption

func SqlConnect

func SqlConnect(ctx context.Context, dbConnection string) (*sql.DB, *pgq.Worker, error)

Types

type CallbackWithContext

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

type Consumer

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

Consumer implements messaging.Consumer and interface.autoscaler.qbas.Queue

func NewConsumer

func NewConsumer(db *sql.DB, queueName string, opts ...ConsumerOption) *Consumer

NewConsumer returns a pg queue consumer. A consumer cannot share the worker with another instance

func (*Consumer) Backlog

func (c *Consumer) Backlog(ctx context.Context) (int64, error)

Backlog implements interface.autoscaler.qbas.Queue

func (*Consumer) Pull

func (c *Consumer) Pull(ctx context.Context, cb messaging.Callback) error

Pull implements Consumer

func (*Consumer) Stop

func (c *Consumer) Stop()

type ConsumerOption

type ConsumerOption func(o *Consumer)

type Publisher

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

Publisher implements messaging.Publisher

func NewPublisher

func NewPublisher(w *pgq.Worker, queueName string, opts ...PublisherOption) *Publisher

NewPublisher returns a pg queue publisher. A publisher can share its worker with another instance

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, data ...[]byte) error

Publish implements Publisher

type PublisherOption

type PublisherOption func(o *Publisher)

func WithJobRetryWaits

func WithJobRetryWaits(waits []time.Duration) PublisherOption

func WithMaxRetries

func WithMaxRetries(maxRetries int) PublisherOption