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

v10

v10.1.0

Jan 22, 2021

Changes in this version

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

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

+ func PutWriteBuffer(wb *WriteBuffer)

+ type BadConnError struct

+ func (e BadConnError) Error() string

+ func (e BadConnError) Unwrap() error

+ type BufReader struct

+ Columns [][]byte

+ func NewBufReader(rd io.Reader) *BufReader

+ func (b *BufReader) Available() int

+ func (b *BufReader) Buffered() int

+ func (b *BufReader) Bytes() []byte

+ func (b *BufReader) BytesReader(n int) *BytesReader

+ func (b *BufReader) Discard(n int) (discarded int, err error)

+ func (b *BufReader) Read(p []byte) (n int, err error)

+ func (b *BufReader) ReadByte() (byte, error)

+ func (b *BufReader) ReadBytes(fn func(byte) bool) (line []byte, err error)

+ func (b *BufReader) ReadFull() ([]byte, error)

+ func (b *BufReader) ReadFullTemp() ([]byte, error)

+ func (b *BufReader) ReadN(n int) (line []byte, err error)

+ func (b *BufReader) ReadSlice(delim byte) (line []byte, err error)

+ func (b *BufReader) Reset(rd io.Reader)

+ func (b *BufReader) SetAvailable(n int)

+ func (b *BufReader) UnreadByte() error

+ type BytesReader struct

+ func NewBytesReader(b []byte) *BytesReader

+ func (r *BytesReader) Buffered() int

+ func (r *BytesReader) Bytes() []byte

+ func (r *BytesReader) Discard(n int) (int, error)

+ func (r *BytesReader) Read(b []byte) (n int, err error)

+ func (r *BytesReader) ReadByte() (byte, error)

+ func (r *BytesReader) ReadBytes(fn func(byte) bool) ([]byte, error)

+ func (r *BytesReader) ReadFull() ([]byte, error)

+ func (r *BytesReader) ReadFullTemp() ([]byte, error)

+ func (r *BytesReader) ReadN(n int) ([]byte, error)

+ func (r *BytesReader) ReadSlice(delim byte) ([]byte, error)

+ func (r *BytesReader) Reset(b []byte)

+ func (r *BytesReader) UnreadByte() 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, fn func(rd *BufReader) error) error

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

+ func (cn *Conn) WriteBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) 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 Reader interface

+ Buffered func() int

+ Bytes func() []byte

+ Discard func(int) (int, error)

+ Read func([]byte) (int, error)

+ ReadByte func() (byte, error)

+ ReadFull func() ([]byte, error)

+ ReadFullTemp func() ([]byte, error)

+ ReadSlice func(byte) ([]byte, error)

+ UnreadByte func() error

+ 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 GetWriteBuffer() *WriteBuffer

+ func NewWriteBuffer() *WriteBuffer

+ func (buf *WriteBuffer) FinishMessage()

+ func (buf *WriteBuffer) FinishNullParam()

+ func (buf *WriteBuffer) FinishParam()

+ func (buf *WriteBuffer) Query() []byte

+ 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)

v10.0.0-alpha.4

May 23, 2020

v10.0.0-alpha.3

May 23, 2020

v10.0.0-alpha.2

May 23, 2020

v10.0.0-alpha.1

May 23, 2020

Other modules containing this package

github.com/nibeh/pg

github.com/nibeh/pg/v9