type github.com/go-pg/pg/v10/internal/pool.ConnPool
34 uses
github.com/go-pg/pg/v10/internal/pool (current package)
pool.go#L65: type ConnPool struct {
pool.go#L87: var _ Pooler = (*ConnPool)(nil)
pool.go#L89: func NewConnPool(opt *Options) *ConnPool {
pool.go#L90: p := &ConnPool{
pool.go#L109: func (p *ConnPool) checkMinIdleConns() {
pool.go#L128: func (p *ConnPool) addIdleConn() error {
pool.go#L141: func (p *ConnPool) NewConn(c context.Context) (*Conn, error) {
pool.go#L145: func (p *ConnPool) newConn(c context.Context, pooled bool) (*Conn, error) {
pool.go#L167: func (p *ConnPool) dialConn(c context.Context, pooled bool) (*Conn, error) {
pool.go#L190: func (p *ConnPool) tryDial() {
pool.go#L209: func (p *ConnPool) setLastDialError(err error) {
pool.go#L215: func (p *ConnPool) getLastDialError() error {
pool.go#L223: func (p *ConnPool) Get(ctx context.Context) (*Conn, error) {
pool.go#L262: func (p *ConnPool) getTurn() {
pool.go#L266: func (p *ConnPool) waitTurn(c context.Context) error {
pool.go#L302: func (p *ConnPool) freeTurn() {
pool.go#L306: func (p *ConnPool) popIdle() *Conn {
pool.go#L319: func (p *ConnPool) Put(ctx context.Context, cn *Conn) {
pool.go#L332: func (p *ConnPool) Remove(ctx context.Context, cn *Conn, reason error) {
pool.go#L338: func (p *ConnPool) CloseConn(cn *Conn) error {
pool.go#L343: func (p *ConnPool) removeConnWithLock(cn *Conn) {
pool.go#L349: func (p *ConnPool) removeConn(cn *Conn) {
pool.go#L362: func (p *ConnPool) closeConn(cn *Conn) error {
pool.go#L370: func (p *ConnPool) Len() int {
pool.go#L378: func (p *ConnPool) IdleLen() int {
pool.go#L385: func (p *ConnPool) Stats() *Stats {
pool.go#L398: func (p *ConnPool) closed() bool {
pool.go#L402: func (p *ConnPool) Filter(fn func(*Conn) bool) error {
pool.go#L416: func (p *ConnPool) Close() error {
pool.go#L437: func (p *ConnPool) reaper(frequency time.Duration) {
pool.go#L454: func (p *ConnPool) ReapStaleConns() (int, error) {
pool.go#L475: func (p *ConnPool) reapStaleConn() *Conn {
pool.go#L492: func (p *ConnPool) isStaleConn(cn *Conn) bool {
github.com/go-pg/pg/v10
options.go#L265: func newConnPool(opt *Options) *pool.ConnPool {