sqlchelpers

Documentation

Index

• Variables
• func BoolFromBoolean(v bool) pgtype.Bool
• func DeferRollback(ctx context.Context, l *zerolog.Logger, rollback func(context.Context) error)
• func DurationToPgInterval(d time.Duration) pgtype.Interval
• func PrepareTx(ctx context.Context, pool *pgxpool.Pool, l *zerolog.Logger, timeoutMs int) (pgx.Tx, func(context.Context) error, func(), error)
• func TextFromStr(str string) pgtype.Text
• func TimestampFromTime(t time.Time) pgtype.Timestamp
• func TimestamptzFromTime(t time.Time) pgtype.Timestamptz
• func ToInt(i int32) pgtype.Int4
• func UUIDFromStr(uuid string) pgtype.UUID
• func UUIDToStr(uuid pgtype.UUID) string
• func UniqueSet(uuids []pgtype.UUID) []pgtype.UUID

Variables

var DeadlockRetry = func(l *zerolog.Logger, f func() error) error {
	return genericRetry(l.Warn(), 3, f, "deadlock", func(err error) (bool, error) {
		return strings.Contains(err.Error(), "deadlock detected"), err
	}, 50*time.Millisecond, 200*time.Millisecond)
}

Functions

func BoolFromBoolean

func BoolFromBoolean(v bool) pgtype.Bool

func DeferRollback

func DeferRollback(ctx context.Context, l *zerolog.Logger, rollback func(context.Context) error)

func DurationToPgInterval

func DurationToPgInterval(d time.Duration) pgtype.Interval

func PrepareTx

func PrepareTx(ctx context.Context, pool *pgxpool.Pool, l *zerolog.Logger, timeoutMs int) (pgx.Tx, func(context.Context) error, func(), error)

func TextFromStr

func TextFromStr(str string) pgtype.Text

func TimestampFromTime

func TimestampFromTime(t time.Time) pgtype.Timestamp

func TimestamptzFromTime

func TimestamptzFromTime(t time.Time) pgtype.Timestamptz

func ToInt

func ToInt(i int32) pgtype.Int4

func UUIDFromStr

func UUIDFromStr(uuid string) pgtype.UUID

func UUIDToStr

func UUIDToStr(uuid pgtype.UUID) string

func UniqueSet

func UniqueSet(uuids []pgtype.UUID) []pgtype.UUID