pgq

Documentation

Index

• type Queue
  • func Open(conString, queueName string) (*Queue, error)
  • func (q *Queue) Close() error
  • func (q *Queue) Dequeue(ctx context.Context, kinds []string, fn worker.DequeueFn) error
  • func (q *Queue) Enqueue(ctx context.Context, jobs ...worker.Job) error

Types

type Queue

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

Queue implements a JobQueue backed by PostgreSQL. Refer Open() for initialising.

func Open

func Open(conString, queueName string) (*Queue, error)

Open returns a JobQueue implementation backed by the PostgreSQL instance discovered by the conString. The table used for the queue will be based on the queueName. Necessary migrations will be done automatically.

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Dequeue

func (q *Queue) Dequeue(ctx context.Context, kinds []string, fn worker.DequeueFn) error

func (*Queue) Enqueue

func (q *Queue) Enqueue(ctx context.Context, jobs ...worker.Job) error