pool

package

v6.3.2+incompatible Latest Latest Go to latest Published: Jun 21, 2017 License: BSD-2-Clause Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bitgate/pg

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
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")

View Source

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

Functions ¶

This section is empty.

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 ¶

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 ¶

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

func (*Conn) SetNetConn ¶

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

func (*Conn) SetReadWriteTimeout ¶

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() error

func (*ConnPool) CloseConn ¶

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

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

func (*ConnPool) Stats ¶

func (p *ConnPool) Stats() *Stats

type Options ¶

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 {
	NewConn() (*Conn, error)
	CloseConn(*Conn) error

	Get() (*Conn, bool, error)
	Put(*Conn) error
	Remove(*Conn) error

	Len() int
	FreeLen() int
	Stats() *Stats

	Close() error
}

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 ¶

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

func NewWriteBuffer ¶

func NewWriteBuffer() *WriteBuffer

func (*WriteBuffer) FinishMessage ¶

func (buf *WriteBuffer) FinishMessage()

func (*WriteBuffer) FinishNullParam ¶

func (buf *WriteBuffer) FinishNullParam()

func (*WriteBuffer) FinishParam ¶

func (buf *WriteBuffer) FinishParam()

func (*WriteBuffer) ReadFrom ¶

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

func (*WriteBuffer) Reset ¶

func (buf *WriteBuffer) Reset()

func (*WriteBuffer) StartMessage ¶

func (buf *WriteBuffer) StartMessage(c byte)

func (*WriteBuffer) StartParam ¶

func (buf *WriteBuffer) StartParam()

func (*WriteBuffer) Write ¶

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

func (*WriteBuffer) WriteByte ¶

func (buf *WriteBuffer) WriteByte(c byte)

func (*WriteBuffer) WriteBytes ¶

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

func (*WriteBuffer) WriteInt16 ¶

func (buf *WriteBuffer) WriteInt16(num int16)

func (*WriteBuffer) WriteInt32 ¶

func (buf *WriteBuffer) WriteInt32(num int32)

func (*WriteBuffer) WriteString ¶

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