zdb

package

Go to main page

Versions in this module

v1

v1.4.2

Apr 26, 2024

v1.4.1

Apr 25, 2024

v1.4.0

Apr 25, 2024

v1.3.1

Mar 10, 2024

Changes in this version

type Pool

+ Debug bool

v1.3.0

Mar 6, 2024

Changes in this version

type Pool

+ func NewMaster(conn string) *Pool

v1.2.1

Dec 25, 2023

v1.2.0

Dec 25, 2023

v1.1.1

Dec 11, 2023

v1.1.0

Dec 10, 2023

v1.0.9

Nov 28, 2023

v1.0.8

Nov 28, 2023

v1.0.7

Nov 19, 2023

v1.0.6

Nov 19, 2023

Changes in this version

type Stat

+ ID string

v1.0.5

Nov 19, 2023

v1.0.4

Nov 18, 2023

v1.0.3

Nov 18, 2023

v1.0.2

Nov 18, 2023

v1.0.1

Nov 17, 2023

v1.0.0

Nov 17, 2023

Changes in this version

+ const ConnModeAsync

+ const ConnModeMaster

+ const ConnModeSync

+ var ErrNoRows = pgx.ErrNoRows

+ func IsEmpty(err error) bool

+ type Balance int

+ const BalanceLeastConn

+ const BalanceRoundRobin

+ type Conn struct

+ Alive bool

+ Index int

+ Mode connMode

+ PingTry int

+ func (c Conn) ToString() string

+ type Logger interface

+ Printf func(format string, v ...any)

+ type Opts interface

+ Opts func() (sql string, args map[string]any)

+ type Pool struct

+ Balance Balance

+ Continues []string

+ ContinuesTry []string

+ PgTsFormat string

+ PingTimout time.Duration

+ PingTry int

+ SrvAsync []*Conn

+ SrvMaster *Conn

+ SrvSync []*Conn

+ TryOnError int

+ TryOnSleep time.Duration

+ UseGoTime bool

+ func New(ctx context.Context) *Pool

+ func NewDefault() *Pool

+ func (d *Pool) Any(dst any, sql string, args ...any) error

+ func (d *Pool) AnyAsync(dst any, sql string, args ...any) error

+ func (d *Pool) Get(dst any, sql string, args ...any) error

+ func (d *Pool) GetAsync(dst any, sql string, args ...any) error

+ func (d *Pool) GetAsyncNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) GetAsyncOpts(dst any, opts Opts) error

+ func (d *Pool) GetNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) GetOpts(dst any, opts Opts) error

+ func (d *Pool) IsAlive() bool

+ func (d *Pool) NewConn(mode connMode, pgConnString string) error

+ func (d *Pool) NewConns(mode connMode, pgConnString ...string) error

+ func (d *Pool) Ping(q *Conn) (err error)

+ func (d *Pool) Select(dst any, sql string, args ...any) error

+ func (d *Pool) SelectAsync(dst any, sql string, args ...any) error

+ func (d *Pool) SelectAsyncNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) SelectAsyncOpts(dst any, opts Opts) error

+ func (d *Pool) SelectNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) SelectOpts(dst any, opts Opts) error

+ func (d *Pool) Start()

+ func (d *Pool) Stat(q *Conn) *Stat

+ func (d *Pool) StatMaster() *Stat

+ func (d *Pool) StatPool() []*Stat

+ func (d *Pool) StatPoolTotal() *Stat

+ func (d *Pool) Stop()

+ func (d *Pool) WAny(dst any, sql string, args ...any) error

+ func (d *Pool) WExec(sql string, args ...any) error

+ func (d *Pool) WExecNamed(sql string, args map[string]any) error

+ func (d *Pool) WExecOpts(opts Opts) error

+ func (d *Pool) WGet(dst any, sql string, args ...any) error

+ func (d *Pool) WGetNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) WGetOpts(dst any, opts Opts) error

+ func (d *Pool) WSelect(dst any, sql string, args ...any) error

+ func (d *Pool) WSelectNamed(dst any, sql string, args map[string]any) error

+ func (d *Pool) WSelectOpts(dst any, opts Opts) error

+ func (d *Pool) WithContext(ctx context.Context) *Pool

+ func (d *Pool) WithDeadline(dur time.Time) *Pool

+ func (d *Pool) WithTimeout(dur time.Duration) *Pool

+ type Stat struct

+ AcquireCount int64

+ AcquireDuration time.Duration

+ AcquiredConns int32

+ CanceledAcquireCount int64

+ ConstructingConns int32

+ EmptyAcquireCount int64

+ Host string

+ Id string

+ IdleConns int32

+ MaxConns int32

+ MaxIdleDestroyCount int64

+ MaxLifetimeDestroyCount int64

+ Mode connMode

+ NewConnsCount int64

+ Port uint16

+ TotalConns int32

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL