pg

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)