pool

Apr 13, 2019

retracted

Changes in this version

+ var ErrClosed = errors.New("client is closed")

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

+ type Conn struct

+ func NewConn(client ldap.Client) *Conn

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

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

+ type ConnPool struct

+ func NewPool(opt *Options) *ConnPool

+ func (p *ConnPool) Close() error

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

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

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

+ func (p *ConnPool) IdleLen() int

+ func (p *ConnPool) Len() int

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

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

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

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

+ type Options struct

+ Factory func() (ldap.Client, 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

+ Get func() (*Conn, error)

+ IdleLen func() int

+ Len func() int

+ Put func(c *Conn)

+ Stats func() *Stats

+ type Stats struct

+ Hits uint32

+ IdleConns uint32

+ Misses uint32

+ StaleConns uint32

+ Timeouts uint32

+ TotalConns uint32