pgxqueue

Documentation

Overview

Package pgxqueue implements ListenerPool for PostgreSQL's LISTEN/NOTIFY.

Index

• type PgxListenerPool
  • func NewPgxListenerPool(ctx context.Context, conn *pgxpool.Pool) *PgxListenerPool

Types

type PgxListenerPool

type PgxListenerPool struct {
	queue.ListenerPool[string]

	Reconnect bool
	// contains filtered or unexported fields
}

A PgxListenerPool is listens with PostgreSQL's LISTEN/NOTIFY, using a *pgxpool.Pool. PgxListenerPool will reconnect when a connection is dropped, but note that Postgres only offers at-most-once delivery.

func NewPgxListenerPool

func NewPgxListenerPool(ctx context.Context, conn *pgxpool.Pool) *PgxListenerPool

NewPgxListenerPool creates a new PgxListenerPool.