Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pool

package

Go to main page

Versions in this module

v9

v9.0.0

Mar 24, 2020

Changes in this version

+ var ErrClosed = errors.New("pg: database is closed")

+ var ErrPoolTimeout = errors.New("pg: connection pool timeout")

+ type BadConnError struct

+ func (e BadConnError) Error() string

+ func (e BadConnError) Unwrap() error

+ type Conn struct

+ Inited bool

+ ProcessID int32

+ SecretKey int32

+ func NewConn(netConn net.Conn) *Conn

+ func (cn *Conn) Close() error

+ func (cn *Conn) NetConn() net.Conn

+ func (cn *Conn) NextID() string

+ func (cn *Conn) RemoteAddr() net.Addr

+ func (cn *Conn) SetNetConn(netConn net.Conn)

+ func (cn *Conn) SetUsedAt(tm time.Time)

+ func (cn *Conn) UsedAt() time.Time

+ func (cn *Conn) WithReader(ctx context.Context, timeout time.Duration, ...) error

+ func (cn *Conn) WithWriter(ctx context.Context, timeout time.Duration, fn func(wb *WriteBuffer) error) error

+ type ConnPool struct

+ func NewConnPool(opt *Options) *ConnPool

+ func (p *ConnPool) Close() error

+ func (p *ConnPool) CloseConn(cn *Conn) error

+ func (p *ConnPool) Filter(fn func(*Conn) bool) error

+ func (p *ConnPool) Get(c context.Context) (*Conn, error)

+ func (p *ConnPool) IdleLen() int

+ func (p *ConnPool) Len() int

+ func (p *ConnPool) NewConn(c context.Context) (*Conn, error)

+ func (p *ConnPool) Put(cn *Conn)

+ func (p *ConnPool) ReapStaleConns() (int, error)

+ func (p *ConnPool) Remove(cn *Conn, reason error)

+ func (p *ConnPool) Stats() *Stats

+ type Options struct

+ Dialer func(context.Context) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MinIdleConns int

+ OnClose func(*Conn) error

+ PoolSize int

+ PoolTimeout time.Duration

+ type Pooler interface

+ Close func() error

+ CloseConn func(*Conn) error

+ Get func(context.Context) (*Conn, error)

+ IdleLen func() int

+ Len func() int

+ NewConn func(context.Context) (*Conn, error)

+ Put func(*Conn)

+ Remove func(*Conn, error)

+ Stats func() *Stats

+ type SingleConnPool struct

+ func NewSingleConnPool(pool Pooler) *SingleConnPool

+ func (p *SingleConnPool) Close() error

+ func (p *SingleConnPool) CloseConn(cn *Conn) error

+ func (p *SingleConnPool) Get(c context.Context) (*Conn, error)

+ func (p *SingleConnPool) IdleLen() int

+ func (p *SingleConnPool) Len() int

+ func (p *SingleConnPool) NewConn(c context.Context) (*Conn, error)

+ func (p *SingleConnPool) Put(cn *Conn)

+ func (p *SingleConnPool) Remove(cn *Conn, reason error)

+ func (p *SingleConnPool) Reset() error

+ func (p *SingleConnPool) SetConn(cn *Conn)

+ func (p *SingleConnPool) Stats() *Stats

+ type Stats struct

+ Hits uint32

+ IdleConns uint32

+ Misses uint32

+ StaleConns uint32

+ Timeouts uint32

+ TotalConns uint32

+ type WriteBuffer struct

+ Bytes []byte

+ func NewWriteBuffer() *WriteBuffer

+ func (buf *WriteBuffer) FinishMessage()

+ func (buf *WriteBuffer) FinishNullParam()

+ func (buf *WriteBuffer) FinishParam()

+ func (buf *WriteBuffer) ReadFrom(r io.Reader) (int64, error)

+ func (buf *WriteBuffer) Reset()

+ func (buf *WriteBuffer) ResetBuffer(b []byte)

+ func (buf *WriteBuffer) StartMessage(c byte)

+ func (buf *WriteBuffer) StartParam()

+ func (buf *WriteBuffer) Write(b []byte) (int, error)

+ func (buf *WriteBuffer) WriteByte(c byte) error

+ func (buf *WriteBuffer) WriteBytes(b []byte)

+ func (buf *WriteBuffer) WriteInt16(num int16)

+ func (buf *WriteBuffer) WriteInt32(num int32)

+ func (buf *WriteBuffer) WriteString(s string)

v9.0.0-beta.5

Mar 24, 2020

v9.0.0-beta.4

Mar 24, 2020

Other modules containing this package

github.com/whenspeakteam/pg