The highest tagged major version is v8.

pool

package

v5.3.3 Latest Latest Go to latest Published: Mar 4, 2017 License: BSD-2-Clause Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/go-pg/pg

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func SetIdleCheckFrequency(d time.Duration)
type Conn
- func NewConn(netConn net.Conn) *Conn
type ConnPool
- func NewConnPool(opt *Options) *ConnPool
type Options
type Pooler
type Stats
type WriteBuffer
- func NewWriteBuffer() *WriteBuffer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrClosed      = errors.New("pg: database is closed")
	ErrPoolTimeout = errors.New("pg: connection pool timeout")
)

Functions ¶

func SetIdleCheckFrequency ¶

func SetIdleCheckFrequency(d time.Duration)

Types ¶

type Conn ¶

type Conn struct {
	Rd      *bufio.Reader
	Columns [][]byte

	Wr *WriteBuffer

	InitedAt time.Time
	UsedAt   time.Time

	ProcessId int32
	SecretKey int32
	// contains filtered or unexported fields
}

func NewConn ¶

func NewConn(netConn net.Conn) *Conn

func (*Conn) CheckHealth ¶

func (cn *Conn) CheckHealth() error

func (*Conn) Close ¶

func (cn *Conn) Close() error

func (*Conn) FlushWriter ¶ added in v5.3.0

func (cn *Conn) FlushWriter() error

func (*Conn) NetConn ¶

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

func (*Conn) NextId ¶

func (cn *Conn) NextId() string

func (*Conn) ReadN ¶

func (cn *Conn) ReadN(n int) ([]byte, error)

func (*Conn) RemoteAddr ¶ added in v5.3.0

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

func (*Conn) SetNetConn ¶ added in v5.1.5

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

func (*Conn) SetReadWriteTimeout ¶ added in v5.1.5

func (cn *Conn) SetReadWriteTimeout(rt, wt time.Duration)

type ConnPool ¶

type ConnPool struct {
	// contains filtered or unexported fields
}

func NewConnPool ¶

func NewConnPool(opt *Options) *ConnPool

func (*ConnPool) Close ¶

func (p *ConnPool) Close() (retErr error)

func (*ConnPool) Closed ¶

func (p *ConnPool) Closed() bool

func (*ConnPool) FreeLen ¶

func (p *ConnPool) FreeLen() int

FreeLen returns number of free connections.

func (*ConnPool) Get ¶

func (p *ConnPool) Get() (*Conn, bool, error)

Get returns existed connection from the pool or creates a new one.

func (*ConnPool) Len ¶

func (p *ConnPool) Len() int

Len returns total number of connections.

func (*ConnPool) NewConn ¶

func (p *ConnPool) NewConn() (*Conn, error)

func (*ConnPool) PopFree ¶

func (p *ConnPool) PopFree() *Conn

func (*ConnPool) Put ¶

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

func (*ConnPool) ReapStaleConns ¶

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

func (*ConnPool) Remove ¶

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

func (*ConnPool) Stats ¶

func (p *ConnPool) Stats() *Stats

type Options ¶ added in v5.2.0

type Options struct {
	Dial    func() (net.Conn, error)
	OnClose func(*Conn) error

	PoolSize           int
	PoolTimeout        time.Duration
	IdleTimeout        time.Duration
	IdleCheckFrequency time.Duration
	MaxAge             time.Duration
}

type Pooler ¶

type Pooler interface {
	Get() (*Conn, bool, error)
	Put(*Conn) error
	Remove(*Conn, error) error
	Len() int
	FreeLen() int
	Stats() *Stats
	Close() error
	Closed() bool
}

type Stats ¶

type Stats struct {
	Requests uint32 // number of times a connection was requested by the pool
	Hits     uint32 // number of times free connection was found in the pool
	Timeouts uint32 // number of times a wait timeout occurred

	TotalConns uint32 // the number of total connections in the pool
	FreeConns  uint32 // the number of free connections in the pool
}

Stats contains pool state information and accumulated stats.

type WriteBuffer ¶ added in v5.2.0

type WriteBuffer struct {
	Bytes []byte
	// contains filtered or unexported fields
}

func NewWriteBuffer ¶ added in v5.2.0

func NewWriteBuffer() *WriteBuffer

func (*WriteBuffer) FinishMessage ¶ added in v5.2.0

func (buf *WriteBuffer) FinishMessage()

func (*WriteBuffer) FinishNullParam ¶ added in v5.2.0

func (buf *WriteBuffer) FinishNullParam()

func (*WriteBuffer) FinishParam ¶ added in v5.2.0

func (buf *WriteBuffer) FinishParam()

func (*WriteBuffer) ReadFrom ¶ added in v5.2.0

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

func (*WriteBuffer) Reset ¶ added in v5.2.0

func (buf *WriteBuffer) Reset()

func (*WriteBuffer) StartMessage ¶ added in v5.2.0

func (buf *WriteBuffer) StartMessage(c byte)

func (*WriteBuffer) StartParam ¶ added in v5.2.0

func (buf *WriteBuffer) StartParam()

func (*WriteBuffer) Write ¶ added in v5.2.0

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

func (*WriteBuffer) WriteByte ¶ added in v5.2.0

func (buf *WriteBuffer) WriteByte(c byte)

func (*WriteBuffer) WriteBytes ¶ added in v5.2.0

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

func (*WriteBuffer) WriteInt16 ¶ added in v5.2.0

func (buf *WriteBuffer) WriteInt16(num int16)

func (*WriteBuffer) WriteInt32 ¶ added in v5.2.0

func (buf *WriteBuffer) WriteInt32(num int32)

func (*WriteBuffer) WriteString ¶ added in v5.2.0

func (buf *WriteBuffer) WriteString(s string)

Source Files ¶

View all Source files

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