pg

Feb 23, 2026

Changes in this version

+ const PingChannel

+ var ErrListenerOverflow = errors.New("listener channel full")

+ func SendListenerPing(ctx context.Context, db DBExec) error

+ type FanOutOption func(*fanOutConfig)

+ func WithOverflowPolicy(p OverflowPolicy) FanOutOption

+ type OverflowPolicy int

+ const OverflowDrop

+ const OverflowError

+ type Subscriber struct

+ func NewSubscriber(logger *slog.Logger, pool *pgxpool.Pool, channels []ChannelSubscription, ...) *Subscriber

+ func (s *Subscriber) Run(ctx context.Context) error

+ type SubscriberOption func(*Subscriber)

+ func WithOnReconnect(fn func(ctx context.Context) error) SubscriberOption

+ func WithPingDB(db DBExec) SubscriberOption

+ func WithPingGrace(d time.Duration) SubscriberOption

+ func WithPingInterval(d time.Duration) SubscriberOption

Dec 18, 2025

Changes in this version

+ func Int32(n int32) pgtype.Int4

Jun 17, 2025

Changes in this version

+ func Int64(n int64) pgtype.Int8

Mar 28, 2025

Changes in this version

+ func RunInJobLock(ctx context.Context, db *pgxpool.Pool, logger *slog.Logger, serviceName string, ...) error

Mar 3, 2025

Changes in this version

+ func Publish(ctx context.Context, db DBExec, channel string, message any) error

+ type DBExec interface

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

type FanOut

+ func (f *FanOut[T]) Publish(ctx context.Context, db DBExec, msg T) error

Jan 29, 2025

Changes in this version

+ func PInt64(n *int64) pgtype.Int8

Jan 28, 2025

Changes in this version

+ func Subscribe(ctx context.Context, logger *slog.Logger, pool *pgxpool.Pool, ...)

+ type ChannelSubscription interface

+ ChannelName func() string

+ NotifyWithPayload func(data []byte) error

+ type FanOut struct

+ func NewFanOut[T any](channel string) *FanOut[T]

+ func (f *FanOut[T]) ChannelName() string

+ func (f *FanOut[T]) Listen(ctx context.Context, l chan T, test func(v T) bool)

+ func (f *FanOut[T]) ListenAll(ctx context.Context, l chan T)

+ func (f *FanOut[T]) Notify(msg T)

+ func (f *FanOut[T]) NotifyWithPayload(data []byte) error

Oct 25, 2024

Changes in this version

+ func Rollback(tx pgx.Tx, outErr *error)

Mar 12, 2024

Changes in this version

+ func PInt32(n *int32) pgtype.Int4

Feb 13, 2024

Changes in this version

+ func PUUID(u *uuid.UUID) pgtype.UUID

+ func Text(s string) pgtype.Text

+ func ToUUIDPointer(v pgtype.UUID) *uuid.UUID

+ func UUID(u uuid.UUID) pgtype.UUID

Jan 25, 2024

Changes in this version

+ func PBool(b *bool) pgtype.Bool

Nov 23, 2023

Changes in this version

type JobLock

+ func (jl *JobLock) Identity() string

Sep 13, 2023

Changes in this version

+ func PText(s *string) pgtype.Text

Aug 22, 2023

Changes in this version

+ func Date(t time.Time) pgtype.Date

+ func PInt2(n *int16) pgtype.Int2

+ func PTime(t *time.Time) pgtype.Timestamptz

Jun 14, 2023

Changes in this version

+ type JobLockOptions struct

+ CheckInterval time.Duration

+ PingInterval time.Duration

+ StaleAfter time.Duration

+ Timeout time.Duration

May 2, 2023

Changes in this version

+ const JobLockStateHeld

+ const JobLockStateLost

+ const JobLockStateNone

+ const JobLockStateReleased

+ func BigintOrNull(n int64) pgtype.Int8

+ func IsConstraintError(err error, constraint string) bool

+ func SafeRollback(ctx context.Context, logger *slog.Logger, tx pgx.Tx, txName string)

+ func SetConnStringVariables(conn string, vars url.Values) (string, error)

+ func TextOrNull(s string) pgtype.Text

+ func Time(t time.Time) pgtype.Timestamptz

+ func TimeOrNull(t time.Time) pgtype.Timestamptz

+ func WithTX(ctx context.Context, logger *slog.Logger, pool TransactionBeginner, ...) error

+ type JobLock struct

+ func NewJobLock(db *pgxpool.Pool, logger *slog.Logger, name string, ...) (*JobLock, error)

+ func (jl *JobLock) RunWithContext(ctx context.Context, fn func(ctx context.Context) error) error

+ func (jl *JobLock) Stop()

+ type JobLockState string

+ type TransactionBeginner interface

+ Begin func(context.Context) (pgx.Tx, error)