package pool

Import Path
	github.com/go-pg/pg/v10/internal/pool (on go.dev)

Dependency Relation
	imports 13 packages, and imported by 4 packages

Involved Source Files

	      conn.go
	      pool.go
	      pool_single.go
	      pool_sticky.go
	      reader.go
	      reader_buf.go
	      reader_bytes.go
	      write_buffer.go
Package-Level Type Names (total 15, all are exported)

	/* sort exporteds by: alphabet | popularity */
	 type BadConnError (struct)

		Fields (only one, which is unexported)
			/* one unexported ... *//* one unexported: */
			wrapped error
		Methods (total 2, both are exported)
			( BadConnError) Error() string
			( BadConnError) Unwrap() error
		Implements (at least one exported)
			 BadConnError : error

	 type BufReader (struct)

		Fields (total 9, none are exported)
			/* 9 unexporteds ... *//* 9 unexporteds: */
			available int
				// bytes available for reading

			brd BytesReader
				// reusable bytes reader

			buf []byte
			bytesRead int64
			err error
			lastByte int
			r int
				// buf read and write positions

			rd io.Reader
				// reader provided by the client

			w int
				// buf read and write positions

		Methods (total 20, in which 15 are exported)
			(*BufReader) Available() int
			(*BufReader) Buffered() int
				Buffered returns the number of bytes that can be read from the current buffer.

			(*BufReader) Bytes() []byte
			(*BufReader) BytesReader(n int) *BytesReader
			(*BufReader) Discard(n int) (discarded int, err error)
				Discard skips the next n bytes, returning the number of bytes discarded.

				If Discard skips fewer than n bytes, it also returns an error.
				If 0 <= n <= b.Buffered(), Discard is guaranteed to succeed without
				reading from the underlying io.BufReader.

			(*BufReader) Read(p []byte) (n int, err error)
			(*BufReader) ReadByte() (byte, error)
			(*BufReader) ReadBytes(fn func(byte) bool) (line []byte, err error)
			(*BufReader) ReadFull() ([]byte, error)
			(*BufReader) ReadFullTemp() ([]byte, error)
			(*BufReader) ReadN(n int) (line []byte, err error)
			(*BufReader) ReadSlice(delim byte) (line []byte, err error)
				ReadSlice reads until the first occurrence of delim in the input,
				returning a slice pointing at the bytes in the buffer.
				The bytes stop being valid at the next read.
				If ReadSlice encounters an error before finding a delimiter,
				it returns all the data in the buffer and the error itself (often io.EOF).
				ReadSlice fails with error ErrBufferFull if the buffer fills without a delim.
				Because the data returned from ReadSlice will be overwritten
				by the next I/O operation, most clients should use
				ReadBytes or ReadString instead.
				ReadSlice returns err != nil if and only if line does not end in delim.

			(*BufReader) Reset(rd io.Reader)
			(*BufReader) SetAvailable(n int)
			(*BufReader) UnreadByte() error
			/* 5 unexporteds ... *//* 5 unexporteds: */
			(*BufReader) changeAvailable(n int)
			(*BufReader) fill()
				fill reads a new chunk into the buffer.

			(*BufReader) flush() []byte
			(*BufReader) read(buf []byte) (int, error)
			(*BufReader) readErr() error
		Implements (at least 6, in which 5 are exported)
			*BufReader : Reader
			*BufReader : compress/flate.Reader
			*BufReader : io.ByteReader
			*BufReader : io.ByteScanner
			*BufReader : io.Reader
			/* at least one unexported ... *//* at least one unexported: */
			*BufReader : github.com/vmihailenco/msgpack/v5.bufReader
		As Outputs Of (at least one exported)
			func NewBufReader(bufSize int) *BufReader

	 type BytesReader (struct)

		Fields (total 2, neither is exported)
			/* 2 unexporteds ... *//* 2 unexporteds: */
			i int
			s []byte
		Methods (total 12, all are exported)
			(*BytesReader) Buffered() int
			(*BytesReader) Bytes() []byte
			(*BytesReader) Discard(n int) (int, error)
			(*BytesReader) Read(b []byte) (n int, err error)
			(*BytesReader) ReadByte() (byte, error)
			(*BytesReader) ReadBytes(fn func(byte) bool) ([]byte, error)
			(*BytesReader) ReadFull() ([]byte, error)
			(*BytesReader) ReadFullTemp() ([]byte, error)
			(*BytesReader) ReadN(n int) ([]byte, error)
			(*BytesReader) ReadSlice(delim byte) ([]byte, error)
			(*BytesReader) Reset(b []byte)
			(*BytesReader) UnreadByte() error
		Implements (at least 6, in which 5 are exported)
			*BytesReader : Reader
			*BytesReader : compress/flate.Reader
			*BytesReader : io.ByteReader
			*BytesReader : io.ByteScanner
			*BytesReader : io.Reader
			/* at least one unexported ... *//* at least one unexported: */
			*BytesReader : github.com/vmihailenco/msgpack/v5.bufReader
		As Outputs Of (at least 2, both are exported)
			func NewBytesReader(b []byte) *BytesReader
			func (*BufReader).BytesReader(n int) *BytesReader

	 type ColumnAlloc (struct)

		Fields (only one, which is unexported)
			/* one unexported ... *//* one unexported: */
			columns []ColumnInfo
		Methods (total 3, all are exported)
			(*ColumnAlloc) Columns() []ColumnInfo
			(*ColumnAlloc) New(index int16, name []byte) *ColumnInfo
			(*ColumnAlloc) Reset()
		As Outputs Of (at least one exported)
			func NewColumnAlloc() *ColumnAlloc
		As Inputs Of (at least one unexported)
			/* at least one unexported ... *//* at least one unexported: */
			func github.com/go-pg/pg/v10.readRowDescription(rd *ReaderContext, columnAlloc *ColumnAlloc) ([]types.ColumnInfo, error)

	 type ColumnInfo (struct)

		Fields (total 3, all are exported)
			DataType int32
			Index int16
			Name string
		As Outputs Of (at least 4, in which 2 are exported)
			func (*ColumnAlloc).Columns() []ColumnInfo
			func (*ColumnAlloc).New(index int16, name []byte) *ColumnInfo
			/* 2+ unexporteds ... *//* 2+ unexporteds: */
			func github.com/go-pg/pg/v10.readParseDescribeSync(rd *ReaderContext) ([]types.ColumnInfo, error)
			func github.com/go-pg/pg/v10.readRowDescription(rd *ReaderContext, columnAlloc *ColumnAlloc) ([]types.ColumnInfo, error)
		As Inputs Of (at least 9, in which 6 are exported)
			func github.com/go-pg/pg/v10.(*Ints).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10.(*IntSet).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10.(*Strings).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/orm.ColumnScanner.ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/orm.Discard.ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.ReadColumnValue(col types.ColumnInfo, rd types.Reader, n int) (interface{}, error)
			/* 3+ unexporteds ... *//* 3+ unexporteds: */
			func github.com/go-pg/pg/v10.readDataRow(ctx context.Context, rd *ReaderContext, columns []types.ColumnInfo, scanner orm.ColumnScanner) error
			func github.com/go-pg/pg/v10.readExtQueryData(ctx context.Context, rd *ReaderContext, mod interface{}, columns []types.ColumnInfo) (*pg.result, error)
			func github.com/go-pg/pg/v10.(*Stmt).extQueryData(c context.Context, cn *Conn, name string, model interface{}, columns []types.ColumnInfo, params ...interface{}) (pg.Result, error)

	 type Conn (struct)

		Fields (total 9, in which 3 are exported)
			Inited bool
			ProcessID int32
			SecretKey int32
			/* 6 unexporteds ... *//* 6 unexporteds: */
			createdAt time.Time
			lastID int64
			netConn net.Conn
			pooled bool
			rd *ReaderContext
			usedAt uint32
				// atomic

		Methods (total 13, in which 11 are exported)
			(*Conn) Close() error
			(*Conn) LockReader()
			(*Conn) NetConn() net.Conn
			(*Conn) NextID() string
			(*Conn) RemoteAddr() net.Addr
			(*Conn) SetNetConn(netConn net.Conn)
			(*Conn) SetUsedAt(tm time.Time)
			(*Conn) UsedAt() time.Time
			(*Conn) WithReader(ctx context.Context, timeout time.Duration, fn func(rd *ReaderContext) error) error
			(*Conn) WithWriter(ctx context.Context, timeout time.Duration, fn func(wb *WriteBuffer) error) error
			(*Conn) WriteBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) error
			/* 2 unexporteds ... *//* 2 unexporteds: */
			(*Conn) deadline(ctx context.Context, timeout time.Duration) time.Time
			(*Conn) writeBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) error
		Implements (at least one exported)
			*Conn : io.Closer
		As Outputs Of (at least 15, in which 9 are exported)
			func NewConn(netConn net.Conn) *Conn
			func (*ConnPool).Get(ctx context.Context) (*Conn, error)
			func (*ConnPool).NewConn(c context.Context) (*Conn, error)
			func Pooler.Get(context.Context) (*Conn, error)
			func Pooler.NewConn(context.Context) (*Conn, error)
			func (*SingleConnPool).Get(ctx context.Context) (*Conn, error)
			func (*SingleConnPool).NewConn(ctx context.Context) (*Conn, error)
			func (*StickyConnPool).Get(ctx context.Context) (*Conn, error)
			func (*StickyConnPool).NewConn(ctx context.Context) (*Conn, error)
			/* 6+ unexporteds ... *//* 6+ unexporteds: */
			func (*ConnPool).dialConn(c context.Context, pooled bool) (*Conn, error)
			func (*ConnPool).newConn(c context.Context, pooled bool) (*Conn, error)
			func (*ConnPool).popIdle() *Conn
			func (*ConnPool).reapStaleConn() *Conn
			func github.com/go-pg/pg/v10.(*Listener).conn(ctx context.Context) (*Conn, error)
			func github.com/go-pg/pg/v10.(*Listener).connWithLock(ctx context.Context) (*Conn, error)
		As Inputs Of (at least 24, in which 13 are exported)
			func NewSingleConnPool(pool Pooler, cn *Conn) *SingleConnPool
			func (*ConnPool).CloseConn(cn *Conn) error
			func (*ConnPool).Put(ctx context.Context, cn *Conn)
			func (*ConnPool).Remove(ctx context.Context, cn *Conn, reason error)
			func Pooler.CloseConn(*Conn) error
			func Pooler.Put(context.Context, *Conn)
			func Pooler.Remove(context.Context, *Conn, error)
			func (*SingleConnPool).CloseConn(cn *Conn) error
			func (*SingleConnPool).Put(ctx context.Context, cn *Conn)
			func (*SingleConnPool).Remove(ctx context.Context, cn *Conn, reason error)
			func (*StickyConnPool).CloseConn(cn *Conn) error
			func (*StickyConnPool).Put(ctx context.Context, cn *Conn)
			func (*StickyConnPool).Remove(ctx context.Context, cn *Conn, reason error)
			/* 11+ unexporteds ... *//* 11+ unexporteds: */
			func (*ConnPool).closeConn(cn *Conn) error
			func (*ConnPool).isStaleConn(cn *Conn) bool
			func (*ConnPool).removeConn(cn *Conn)
			func (*ConnPool).removeConnWithLock(cn *Conn)
			func (*StickyConnPool).freeConn(ctx context.Context, cn *Conn)
			func github.com/go-pg/pg/v10.terminateConn(cn *Conn) error
			func github.com/go-pg/pg/v10.(*Listener).listen(ctx context.Context, cn *Conn, channels ...string) error
			func github.com/go-pg/pg/v10.(*Listener).releaseConn(ctx context.Context, cn *Conn, err error, allowTimeout bool)
			func github.com/go-pg/pg/v10.(*Listener).unlisten(ctx context.Context, cn *Conn, channels ...string) error
			func github.com/go-pg/pg/v10.(*Stmt).extQuery(c context.Context, cn *Conn, name string, params ...interface{}) (pg.Result, error)
			func github.com/go-pg/pg/v10.(*Stmt).extQueryData(c context.Context, cn *Conn, name string, model interface{}, columns []types.ColumnInfo, params ...interface{}) (pg.Result, error)

	 type ConnPool (struct)

		Fields (total 12, none are exported)
			/* 12 unexporteds ... *//* 12 unexporteds: */
			_closed uint32
				// atomic

			conns []*Conn
			connsMu sync.Mutex
			dialErrorsNum uint32
				// atomic

			idleConns []*Conn
			idleConnsLen int
			lastDialError error
			lastDialErrorMu sync.RWMutex
			opt *Options
			poolSize int
			queue chan struct{}
			stats Stats
		Methods (total 29, in which 11 are exported)
			(*ConnPool) Close() error
			(*ConnPool) CloseConn(cn *Conn) error
			(*ConnPool) Filter(fn func(*Conn) bool) error
			(*ConnPool) Get(ctx context.Context) (*Conn, error)
				Get returns existed connection from the pool or creates a new one.

			(*ConnPool) IdleLen() int
				IdleLen returns number of idle connections.

			(*ConnPool) Len() int
				Len returns total number of connections.

			(*ConnPool) NewConn(c context.Context) (*Conn, error)
			(*ConnPool) Put(ctx context.Context, cn *Conn)
			(*ConnPool) ReapStaleConns() (int, error)
			(*ConnPool) Remove(ctx context.Context, cn *Conn, reason error)
			(*ConnPool) Stats() *Stats
			/* 18 unexporteds ... *//* 18 unexporteds: */
			(*ConnPool) addIdleConn() error
			(*ConnPool) checkMinIdleConns()
			(*ConnPool) closeConn(cn *Conn) error
			(*ConnPool) closed() bool
			(*ConnPool) dialConn(c context.Context, pooled bool) (*Conn, error)
			(*ConnPool) freeTurn()
			(*ConnPool) getLastDialError() error
			(*ConnPool) getTurn()
			(*ConnPool) isStaleConn(cn *Conn) bool
			(*ConnPool) newConn(c context.Context, pooled bool) (*Conn, error)
			(*ConnPool) popIdle() *Conn
			(*ConnPool) reapStaleConn() *Conn
			(*ConnPool) reaper(frequency time.Duration)
			(*ConnPool) removeConn(cn *Conn)
			(*ConnPool) removeConnWithLock(cn *Conn)
			(*ConnPool) setLastDialError(err error)
			(*ConnPool) tryDial()
			(*ConnPool) waitTurn(c context.Context) error
		Implements (at least 2, both are exported)
			*ConnPool : Pooler
			*ConnPool : io.Closer
		As Outputs Of (at least 2, in which 1 are exported)
			func NewConnPool(opt *Options) *ConnPool
			/* at least one unexported ... *//* at least one unexported: */
			func github.com/go-pg/pg/v10.newConnPool(opt *pg.Options) *ConnPool

	 type Options (struct)

		Fields (total 8, all are exported)
			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
		As Inputs Of (at least one exported)
			func NewConnPool(opt *Options) *ConnPool

	 type Pooler (interface)

		Methods (total 9, all are exported)
			( Pooler) Close() error
			( Pooler) CloseConn(*Conn) error
			( Pooler) Get(context.Context) (*Conn, error)
			( Pooler) IdleLen() int
			( Pooler) Len() int
			( Pooler) NewConn(context.Context) (*Conn, error)
			( Pooler) Put(context.Context, *Conn)
			( Pooler) Remove(context.Context, *Conn, error)
			( Pooler) Stats() *Stats
		Implemented By (at least 3, all are exported)
			*ConnPool
			*SingleConnPool
			*StickyConnPool
		Implements (at least one exported)
			 Pooler : io.Closer
		As Inputs Of (at least 2, both are exported)
			func NewSingleConnPool(pool Pooler, cn *Conn) *SingleConnPool
			func NewStickyConnPool(pool Pooler) *StickyConnPool

	 type Reader (interface)

		Methods (total 9, all are exported)
			( Reader) Buffered() int
			( Reader) Bytes() []byte
			( Reader) Discard(int) (int, error)
			( Reader) Read([]byte) (int, error)
			( Reader) ReadByte() (byte, error)
			( Reader) ReadFull() ([]byte, error)
				ReadBytes(fn func(byte) bool) ([]byte, error)
				ReadN(int) ([]byte, error)

			( Reader) ReadFullTemp() ([]byte, error)
			( Reader) ReadSlice(byte) ([]byte, error)
			( Reader) UnreadByte() error
		Implemented By (at least 4, all are exported)
			*BufReader
			*BytesReader
			 ReaderContext
			 github.com/go-pg/pg/v10/internal/parser.StreamingParser
		Implements (at least 5, in which 4 are exported)
			 Reader : compress/flate.Reader
			 Reader : io.ByteReader
			 Reader : io.ByteScanner
			 Reader : io.Reader
			/* at least one unexported ... *//* at least one unexported: */
			 Reader : github.com/vmihailenco/msgpack/v5.bufReader
		As Inputs Of (at least 61, in which 26 are exported)
			func github.com/go-pg/pg/v10/internal/parser.NewStreamingParser(rd Reader) parser.StreamingParser
			func github.com/go-pg/pg/v10.(*Ints).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10.(*IntSet).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10.(*Strings).ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/orm.ColumnScanner.ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/orm.Discard.ScanColumn(col types.ColumnInfo, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/orm.(*Field).ScanValue(strct reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.NewHexDecoder(rd types.Reader, n int) (io.Reader, error)
			func github.com/go-pg/pg/v10/types.ReadBytes(rd types.Reader, b []byte) error
			func github.com/go-pg/pg/v10/types.ReadColumnValue(col types.ColumnInfo, rd types.Reader, n int) (interface{}, error)
			func github.com/go-pg/pg/v10/types.Scan(v interface{}, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.ScanBool(rd types.Reader, n int) (bool, error)
			func github.com/go-pg/pg/v10/types.ScanBytes(rd types.Reader, n int) ([]byte, error)
			func github.com/go-pg/pg/v10/types.ScanFloat32(rd types.Reader, n int) (float32, error)
			func github.com/go-pg/pg/v10/types.ScanFloat64(rd types.Reader, n int) (float64, error)
			func github.com/go-pg/pg/v10/types.ScanInt(rd types.Reader, n int) (int, error)
			func github.com/go-pg/pg/v10/types.ScanInt64(rd types.Reader, n int) (int64, error)
			func github.com/go-pg/pg/v10/types.ScanString(rd types.Reader, n int) (string, error)
			func github.com/go-pg/pg/v10/types.ScanTime(rd types.Reader, n int) (time.Time, error)
			func github.com/go-pg/pg/v10/types.ScanUint64(rd types.Reader, n int) (uint64, error)
			func github.com/go-pg/pg/v10/types.ScanValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.(*Array).ScanValue(rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.ArrayValueScanner.BeforeScanArrayValue(rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.ArrayValueScanner.ScanArrayValue(rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.(*Hstore).ScanValue(rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.ValueScanner.ScanValue(rd types.Reader, n int) error
			/* 35+ unexporteds ... *//* 35+ unexporteds: */
			func github.com/go-pg/pg/v10/orm.newCompositeParser(rd types.Reader) *orm.compositeParser
			func github.com/go-pg/pg/v10/orm.scanJSONValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.decodeSliceInt(rd types.Reader, n int) ([]int, error)
			func github.com/go-pg/pg/v10/types.newArrayParser(rd types.Reader) *types.arrayParser
			func github.com/go-pg/pg/v10/types.newHstoreParser(rd types.Reader) *types.hstoreParser
			func github.com/go-pg/pg/v10/types.scanArrayBytesValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanArrayValueScannerValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanBoolValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanBytesValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanFloat32Value(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanFloat64Array(rd types.Reader, n int) ([]float64, error)
			func github.com/go-pg/pg/v10/types.scanFloat64ArrayValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanFloat64Value(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanIfaceValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanInt64(rd types.Reader, n int, bitSize int) (int64, error)
			func github.com/go-pg/pg/v10/types.scanInt64Array(rd types.Reader, n int) ([]int64, error)
			func github.com/go-pg/pg/v10/types.scanInt64ArrayValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanInt64Value(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanIntArrayValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanIPNetValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanIPValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanJSONRawMessageValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanJSONValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanMapStringString(rd types.Reader, n int) (map[string]string, error)
			func github.com/go-pg/pg/v10/types.scanMapStringStringValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanSQLScanner(scanner sql.Scanner, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanSQLScannerAddrValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanSQLScannerValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanStringArray(rd types.Reader, n int) ([]string, error)
			func github.com/go-pg/pg/v10/types.scanStringArrayValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanStringValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanTimeValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanUint64Value(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanValueScannerAddrValue(v reflect.Value, rd types.Reader, n int) error
			func github.com/go-pg/pg/v10/types.scanValueScannerValue(v reflect.Value, rd types.Reader, n int) error

	 type ReaderContext (struct)

		Fields (total 11, in which 2 are exported)
			BufReader *BufReader
			ColumnAlloc *ColumnAlloc
			/* 9 unexporteds ... *//* 9 unexporteds: */
			BufReader.available int
				// bytes available for reading

			BufReader.brd BytesReader
				// reusable bytes reader

			BufReader.buf []byte
			BufReader.bytesRead int64
			BufReader.err error
			BufReader.lastByte int
			BufReader.r int
				// buf read and write positions

			BufReader.rd io.Reader
				// reader provided by the client

			BufReader.w int
				// buf read and write positions

		Methods (total 20, in which 15 are exported)
			( ReaderContext) Available() int
			( ReaderContext) Buffered() int
				Buffered returns the number of bytes that can be read from the current buffer.

			( ReaderContext) Bytes() []byte
			( ReaderContext) BytesReader(n int) *BytesReader
			( ReaderContext) Discard(n int) (discarded int, err error)
				Discard skips the next n bytes, returning the number of bytes discarded.

				If Discard skips fewer than n bytes, it also returns an error.
				If 0 <= n <= b.Buffered(), Discard is guaranteed to succeed without
				reading from the underlying io.BufReader.

			( ReaderContext) Read(p []byte) (n int, err error)
			( ReaderContext) ReadByte() (byte, error)
			( ReaderContext) ReadBytes(fn func(byte) bool) (line []byte, err error)
			( ReaderContext) ReadFull() ([]byte, error)
			( ReaderContext) ReadFullTemp() ([]byte, error)
			( ReaderContext) ReadN(n int) (line []byte, err error)
			( ReaderContext) ReadSlice(delim byte) (line []byte, err error)
				ReadSlice reads until the first occurrence of delim in the input,
				returning a slice pointing at the bytes in the buffer.
				The bytes stop being valid at the next read.
				If ReadSlice encounters an error before finding a delimiter,
				it returns all the data in the buffer and the error itself (often io.EOF).
				ReadSlice fails with error ErrBufferFull if the buffer fills without a delim.
				Because the data returned from ReadSlice will be overwritten
				by the next I/O operation, most clients should use
				ReadBytes or ReadString instead.
				ReadSlice returns err != nil if and only if line does not end in delim.

			( ReaderContext) Reset(rd io.Reader)
			( ReaderContext) SetAvailable(n int)
			( ReaderContext) UnreadByte() error
			/* 5 unexporteds ... *//* 5 unexporteds: */
			( ReaderContext) changeAvailable(n int)
			( ReaderContext) fill()
				fill reads a new chunk into the buffer.

			( ReaderContext) flush() []byte
			( ReaderContext) read(buf []byte) (int, error)
			( ReaderContext) readErr() error
		Implements (at least 6, in which 5 are exported)
			 ReaderContext : Reader
			 ReaderContext : compress/flate.Reader
			 ReaderContext : io.ByteReader
			 ReaderContext : io.ByteScanner
			 ReaderContext : io.Reader
			/* at least one unexported ... *//* at least one unexported: */
			 ReaderContext : github.com/vmihailenco/msgpack/v5.bufReader
		As Outputs Of (at least 2, both are exported)
			func GetReaderContext() *ReaderContext
			func NewReaderContext() *ReaderContext
		As Inputs Of (at least 23, in which 1 are exported)
			func PutReaderContext(rd *ReaderContext)
			/* 22+ unexporteds ... *//* 22+ unexporteds: */
			func github.com/go-pg/pg/v10.logNotice(rd *ReaderContext, msgLen int) error
			func github.com/go-pg/pg/v10.logParameterStatus(rd *ReaderContext, msgLen int) error
			func github.com/go-pg/pg/v10.readAuthOK(rd *ReaderContext) error
			func github.com/go-pg/pg/v10.readAuthSASLFinal(rd *ReaderContext, client *sasl.Negotiator) error
			func github.com/go-pg/pg/v10.readCloseCompleteMsg(rd *ReaderContext) error
			func github.com/go-pg/pg/v10.readCopyData(rd *ReaderContext, w io.Writer) (*pg.result, error)
			func github.com/go-pg/pg/v10.readCopyInResponse(rd *ReaderContext) error
			func github.com/go-pg/pg/v10.readCopyOutResponse(rd *ReaderContext) error
			func github.com/go-pg/pg/v10.readDataRow(ctx context.Context, rd *ReaderContext, columns []types.ColumnInfo, scanner orm.ColumnScanner) error
			func github.com/go-pg/pg/v10.readError(rd *ReaderContext) (error, error)
			func github.com/go-pg/pg/v10.readExtQuery(rd *ReaderContext) (*pg.result, error)
			func github.com/go-pg/pg/v10.readExtQueryData(ctx context.Context, rd *ReaderContext, mod interface{}, columns []types.ColumnInfo) (*pg.result, error)
			func github.com/go-pg/pg/v10.readInt16(rd *ReaderContext) (int16, error)
			func github.com/go-pg/pg/v10.readInt32(rd *ReaderContext) (int32, error)
			func github.com/go-pg/pg/v10.readMessageType(rd *ReaderContext) (byte, int, error)
			func github.com/go-pg/pg/v10.readNotification(rd *ReaderContext) (channel, payload string, err error)
			func github.com/go-pg/pg/v10.readParseDescribeSync(rd *ReaderContext) ([]types.ColumnInfo, error)
			func github.com/go-pg/pg/v10.readReadyForQuery(rd *ReaderContext) (*pg.result, error)
			func github.com/go-pg/pg/v10.readRowDescription(rd *ReaderContext, columnAlloc *ColumnAlloc) ([]types.ColumnInfo, error)
			func github.com/go-pg/pg/v10.readSimpleQuery(rd *ReaderContext) (*pg.result, error)
			func github.com/go-pg/pg/v10.readSimpleQueryData(ctx context.Context, rd *ReaderContext, mod interface{}) (*pg.result, error)
			func github.com/go-pg/pg/v10.readString(rd *ReaderContext) (string, error)

	 type SingleConnPool (struct)

		Fields (total 3, none are exported)
			/* 3 unexporteds ... *//* 3 unexporteds: */
			cn *Conn
			pool Pooler
			stickyErr error
		Methods (total 9, all are exported)
			(*SingleConnPool) Close() error
			(*SingleConnPool) CloseConn(cn *Conn) error
			(*SingleConnPool) Get(ctx context.Context) (*Conn, error)
			(*SingleConnPool) IdleLen() int
			(*SingleConnPool) Len() int
			(*SingleConnPool) NewConn(ctx context.Context) (*Conn, error)
			(*SingleConnPool) Put(ctx context.Context, cn *Conn)
			(*SingleConnPool) Remove(ctx context.Context, cn *Conn, reason error)
			(*SingleConnPool) Stats() *Stats
		Implements (at least 2, both are exported)
			*SingleConnPool : Pooler
			*SingleConnPool : io.Closer
		As Outputs Of (at least one exported)
			func NewSingleConnPool(pool Pooler, cn *Conn) *SingleConnPool

	 type Stats (struct)
		Stats contains pool state information and accumulated stats.

		Fields (total 6, all are exported)
			Hits uint32
				// number of times free connection was found in the pool

			IdleConns uint32
				// number of idle connections in the pool

			Misses uint32
				// number of times free connection was NOT found in the pool

			StaleConns uint32
				// number of stale connections removed from the pool

			Timeouts uint32
				// number of times a wait timeout occurred

			TotalConns uint32
				// number of total connections in the pool

		As Outputs Of (at least 4, all are exported)
			func (*ConnPool).Stats() *Stats
			func Pooler.Stats() *Stats
			func (*SingleConnPool).Stats() *Stats
			func (*StickyConnPool).Stats() *Stats

	 type StickyConnPool (struct)

		Fields (total 5, none are exported)
			/* 5 unexporteds ... *//* 5 unexporteds: */
			_badConnError atomic.Value
			ch chan *Conn
			pool Pooler
			shared int32
				// atomic

			state uint32
				// atomic

		Methods (total 12, in which 10 are exported)
			(*StickyConnPool) Close() error
			(*StickyConnPool) CloseConn(cn *Conn) error
			(*StickyConnPool) Get(ctx context.Context) (*Conn, error)
			(*StickyConnPool) IdleLen() int
			(*StickyConnPool) Len() int
			(*StickyConnPool) NewConn(ctx context.Context) (*Conn, error)
			(*StickyConnPool) Put(ctx context.Context, cn *Conn)
			(*StickyConnPool) Remove(ctx context.Context, cn *Conn, reason error)
			(*StickyConnPool) Reset(ctx context.Context) error
			(*StickyConnPool) Stats() *Stats
			/* 2 unexporteds ... *//* 2 unexporteds: */
			(*StickyConnPool) badConnError() error
			(*StickyConnPool) freeConn(ctx context.Context, cn *Conn)
		Implements (at least 2, both are exported)
			*StickyConnPool : Pooler
			*StickyConnPool : io.Closer
		As Outputs Of (at least one exported)
			func NewStickyConnPool(pool Pooler) *StickyConnPool

	 type WriteBuffer (struct)

		Fields (total 3, in which 1 are exported)
			Bytes []byte
			/* 2 unexporteds ... *//* 2 unexporteds: */
			msgStart int
			paramStart int
		Methods (total 14, all are exported)
			(*WriteBuffer) FinishMessage()
			(*WriteBuffer) FinishNullParam()
			(*WriteBuffer) FinishParam()
			(*WriteBuffer) Query() []byte
			(*WriteBuffer) ReadFrom(r io.Reader) (int64, error)
			(*WriteBuffer) Reset()
			(*WriteBuffer) StartMessage(c byte)
			(*WriteBuffer) StartParam()
			(*WriteBuffer) Write(b []byte) (int, error)
			(*WriteBuffer) WriteByte(c byte) error
			(*WriteBuffer) WriteBytes(b []byte)
			(*WriteBuffer) WriteInt16(num int16)
			(*WriteBuffer) WriteInt32(num int32)
			(*WriteBuffer) WriteString(s string)
		Implements (at least 4, in which 3 are exported)
			*WriteBuffer : io.ByteWriter
			*WriteBuffer : io.ReaderFrom
			*WriteBuffer : io.Writer
			/* at least one unexported ... *//* at least one unexported: */
			*WriteBuffer : github.com/vmihailenco/msgpack/v5.writer
		As Outputs Of (at least 2, both are exported)
			func GetWriteBuffer() *WriteBuffer
			func NewWriteBuffer() *WriteBuffer
		As Inputs Of (at least 15, in which 2 are exported)
			func PutWriteBuffer(wb *WriteBuffer)
			func (*Conn).WriteBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) error
			/* 13+ unexporteds ... *//* 13+ unexporteds: */
			func (*Conn).writeBuffer(ctx context.Context, timeout time.Duration, wb *WriteBuffer) error
			func github.com/go-pg/pg/v10.writeBindExecuteMsg(buf *WriteBuffer, name string, params ...interface{}) error
			func github.com/go-pg/pg/v10.writeCancelRequestMsg(buf *WriteBuffer, processID, secretKey int32)
			func github.com/go-pg/pg/v10.writeCloseMsg(buf *WriteBuffer, name string)
			func github.com/go-pg/pg/v10.writeCopyData(buf *WriteBuffer, r io.Reader) error
			func github.com/go-pg/pg/v10.writeCopyDone(buf *WriteBuffer)
			func github.com/go-pg/pg/v10.writeFlushMsg(buf *WriteBuffer)
			func github.com/go-pg/pg/v10.writeParseDescribeSyncMsg(buf *WriteBuffer, name, q string)
			func github.com/go-pg/pg/v10.writePasswordMsg(buf *WriteBuffer, password string)
			func github.com/go-pg/pg/v10.writeQueryMsg(buf *WriteBuffer, fmter orm.QueryFormatter, query interface{}, params ...interface{}) error
			func github.com/go-pg/pg/v10.writeSSLMsg(buf *WriteBuffer)
			func github.com/go-pg/pg/v10.writeStartupMsg(buf *WriteBuffer, user, database, appName string)
			func github.com/go-pg/pg/v10.writeSyncMsg(buf *WriteBuffer)


Package-Level Functions (total 13, all are exported)

	 func GetReaderContext() *ReaderContext
	 func GetWriteBuffer() *WriteBuffer
	 func NewBufReader(bufSize int) *BufReader
	 func NewBytesReader(b []byte) *BytesReader
	 func NewColumnAlloc() *ColumnAlloc
	 func NewConn(netConn net.Conn) *Conn
	 func NewConnPool(opt *Options) *ConnPool
	 func NewReaderContext() *ReaderContext
	 func NewSingleConnPool(pool Pooler, cn *Conn) *SingleConnPool
	 func NewStickyConnPool(pool Pooler) *StickyConnPool
	 func NewWriteBuffer() *WriteBuffer
	 func PutReaderContext(rd *ReaderContext)
	 func PutWriteBuffer(wb *WriteBuffer)
Package-Level Variables (total 7, in which 2 are exported)

	  var ErrClosed error
	  var ErrPoolTimeout error
	/* 5 unexporteds ... *//* 5 unexporteds: */
	  var noDeadline time.Time
	  var nullParamLength int32
	  var readerPool sync.Pool
	  var timers sync.Pool
	  var wbPool sync.Pool
Package-Level Constants (total 4, none are exported)

	/* 4 unexporteds ... *//* 4 unexporteds: */
	const defaultBufSize = 66560 // 65kb
	const stateClosed = 2
	const stateDefault = 0
	const stateInited = 1

The pages are generated with Golds v0.4.9. (GOOS=linux GOARCH=amd64)