pg_util

Jul 13, 2020

Changes in this version

+ func ExtractException(err error) string

Jan 5, 2020

Changes in this version

+ type TxStarter interface

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

Dec 31, 2019

Changes in this version

+ func BuildInsert(o InsertOpts) (sql string, args []interface{})

+ func ResuseArgs(args []interface{})

+ type InsertOpts struct

+ Data interface{}

+ Prefix string

+ Suffix string

+ Table string

Nov 17, 2019

Changes in this version

type ListenOpts

+ OnReconnect func()

Sep 8, 2019

Changes in this version

type ListenOpts

+ Context context.Context

Jul 17, 2019

Changes in this version

+ func ExecAll(tx *sql.Tx, q ...string) error

+ func InTransaction(db *sql.DB, fn func(*sql.Tx) error) (err error)

+ func Listen(opts ListenOpts) (err error)

+ type ListenOpts struct

+ Canceller <-chan struct{}

+ Channel string

+ ConnectionURL string

+ DebounceInterval time.Duration

+ OnConnectionLoss func()

+ OnError func(err error)

+ OnMsg func(msg string) error