pgdb

Feb 16, 2022

Changes in this version

+ type SortedOffsetPageParams struct

+ Limit uint64

+ PageNumber uint64

+ Sort []string

+ func (p *SortedOffsetPageParams) ApplyTo(sql squirrel.SelectBuilder, columns map[string]string) squirrel.SelectBuilder

Dec 16, 2021

Changes in this version

+ type EventsListenerOpts struct

+ Handler Handler

+ Log *logan.Entry

+ Payload string

+ TickPeriod time.Duration

+ type EventsRouter interface

+ RunNewListener func(ctx context.Context, opts EventsListenerOpts)

+ func NewEventsRouter(ctx context.Context, opts EventsRouterOpts) EventsRouter

+ type EventsRouterOpts struct

+ Channel string

+ Listener *pq.Listener

+ Log *logan.Entry

+ type Handler interface

+ Handle func(ctx context.Context) error

Jun 16, 2021

Changes in this version

type DB

+ func (db *DB) TransactionWithOptions(opts *sql.TxOptions, fn TransactionFunc) (err error)

Jun 10, 2020

Changes in this version

type Databaser

+ NewListener func() *pq.Listener

May 2, 2020

Changes in this version

+ const OrderTypeAsc

+ const OrderTypeDesc

+ func IsConstraintErr(err error, name string) bool

+ func JSONScan(src, dest interface{}) error

+ func JSONValue(data interface{}) (driver.Value, error)

+ type Connection interface

+ type CursorPageParams struct

+ Cursor uint64

+ Limit uint64

+ Order string

+ func (p *CursorPageParams) ApplyTo(sql squirrel.SelectBuilder, col string) squirrel.SelectBuilder

+ type DB struct

+ func Open(opts Opts) (*DB, error)

+ func (db *DB) Clone() *DB

+ func (db *DB) RawDB() *sql.DB

+ func (db *DB) Transaction(fn TransactionFunc) (err error)

+ type Databaser interface

+ DB func() *DB

+ RawDB func() *sql.DB

+ func NewDatabaser(getter kv.Getter) Databaser

+ type Execer interface

+ Exec func(query squirrel.Sqlizer) error

+ ExecContext func(ctx context.Context, query squirrel.Sqlizer) error

+ ExecRaw func(query string, args ...interface{}) error

+ ExecRawContext func(ctx context.Context, query string, args ...interface{}) error

+ ExecWithResult func(query squirrel.Sqlizer) (sql.Result, error)

+ ExecWithResultContext func(ctx context.Context, query squirrel.Sqlizer) (sql.Result, error)

+ type Getter interface

+ Get func(dest interface{}, query squirrel.Sqlizer) error

+ GetContext func(ctx context.Context, dest interface{}, query squirrel.Sqlizer) error

+ GetRaw func(dest interface{}, query string, args ...interface{}) error

+ GetRawContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ type OffsetPageParams struct

+ Limit uint64

+ Order string

+ PageNumber uint64

+ func (p *OffsetPageParams) ApplyTo(sql squirrel.SelectBuilder, cols ...string) squirrel.SelectBuilder

+ type Opts struct

+ MaxIdleConnections int

+ MaxOpenConnections int

+ URL string

+ type Queryer interface

+ type Selecter interface

+ Select func(dest interface{}, query squirrel.Sqlizer) error

+ SelectContext func(ctx context.Context, dest interface{}, query squirrel.Sqlizer) error

+ SelectRaw func(dest interface{}, query string, args ...interface{}) error

+ SelectRawContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ type Sort string

+ func (s Sort) Desc() bool

+ type Sorts []Sort

+ func (sorts Sorts) ApplyTo(stmt squirrel.SelectBuilder, columns map[string]string) squirrel.SelectBuilder

+ type TransactionFunc func() error

+ type Transactor interface

+ Transaction func(transactionFunc TransactionFunc) (err error)