Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pgmq

package module

Go to main page

Versions in this module

v0

v0.5.1

Jan 1, 2025

v0.5.0

Nov 7, 2024

Changes in this version

type PGMQ

+ func (p *PGMQ) Ping(ctx context.Context) error

v0.4.0

Nov 10, 2023

Changes in this version

type DB

+ Ping func(ctx context.Context) error

type PGMQ

+ func NewFromDB(ctx context.Context, db DB) (*PGMQ, error)

v0.3.0

Nov 8, 2023

Changes in this version

type PGMQ

+ func (p *PGMQ) CreateUnloggedQueue(ctx context.Context, queue string) error

v0.2.0

Sep 27, 2023

Changes in this version

type PGMQ

+ func (p *PGMQ) SendBatchWithDelay(ctx context.Context, queue string, msgs []map[string]any, delay int) ([]int64, error)

+ func (p *PGMQ) SendWithDelay(ctx context.Context, queue string, msg map[string]any, delay int) (int64, error)

v0.1.0

Sep 4, 2023

Changes in this version

+ var ErrNoRows = errors.New("pgmq: no rows in result set")

+ var ErrPing = errors.New("pgmq: failed to ping db")

+ type DB interface

+ Close func()

+ Exec func(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

+ type Message struct

+ EnqueuedAt time.Time

+ Message map[string]any

+ MsgID int64

+ ReadCount int64

+ VT time.Time

+ type PGMQ struct

+ func MustNew(ctx context.Context, connString string) *PGMQ

+ func New(ctx context.Context, connString string) (*PGMQ, error)

+ func (p *PGMQ) Archive(ctx context.Context, queue string, msgID int64) (bool, error)

+ func (p *PGMQ) ArchiveBatch(ctx context.Context, queue string, msgIDs []int64) ([]bool, error)

+ func (p *PGMQ) Close()

+ func (p *PGMQ) CreateQueue(ctx context.Context, queue string) error

+ func (p *PGMQ) Delete(ctx context.Context, queue string, msgID int64) (bool, error)

+ func (p *PGMQ) DeleteBatch(ctx context.Context, queue string, msgIDs []int64) ([]bool, error)

+ func (p *PGMQ) DropQueue(ctx context.Context, queue string) error

+ func (p *PGMQ) Pop(ctx context.Context, queue string) (*Message, error)

+ func (p *PGMQ) Read(ctx context.Context, queue string, vt int64) (*Message, error)

+ func (p *PGMQ) ReadBatch(ctx context.Context, queue string, vt int64, numMsgs int64) ([]*Message, error)

+ func (p *PGMQ) Send(ctx context.Context, queue string, msg map[string]any) (int64, error)

+ func (p *PGMQ) SendBatch(ctx context.Context, queue string, msgs []map[string]any) ([]int64, error)