pool

Mar 19, 2016

Changes in this version

type ConnPool

+ func (p *ConnPool) PopFree() *Conn

type Pooler

+ Remove func(*Conn, error) error

type SingleConnPool

+ func (p *SingleConnPool) Remove(cn *Conn, _ error) error

type StickyConnPool

+ func (p *StickyConnPool) Remove(cn *Conn, reason error) error

Mar 17, 2016

Changes in this version

+ func SetIdleCheckFrequency(d time.Duration)

type Conn

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

type ConnPool

+ OnClose func(*Conn) error

Mar 15, 2016

Changes in this version

type Conn

+ Inited bool

type ConnPool

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

Mar 14, 2016

Changes in this version

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

type Conn

+ NetConn net.Conn

+ func (cn *Conn) Index() int

+ func (cn *Conn) SetIndex(idx int)

type ConnPool

+ func (p *ConnPool) Closed() bool

type Pooler

+ Closed func() bool

type SingleConnPool

+ func (p *SingleConnPool) Closed() bool

type StickyConnPool

+ func (p *StickyConnPool) Closed() bool

Mar 12, 2016

Changes in this version

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

+ var Logger *log.Logger

+ type Conn struct

+ Buf []byte

+ Rd *bufio.Reader

+ ReadTimeout time.Duration

+ UsedAt time.Time

+ WriteTimeout time.Duration

+ func NewConn(netConn net.Conn) *Conn

+ func (cn *Conn) Close() error

+ func (cn *Conn) IsStale(timeout time.Duration) bool

+ func (cn *Conn) Read(b []byte) (int, error)

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

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

+ func (cn *Conn) Write(b []byte) (int, error)

+ type ConnPool struct

+ DialLimiter *ratelimit.RateLimiter

+ func NewConnPool(dial dialer, poolSize int, poolTimeout, idleTimeout time.Duration) *ConnPool

+ func (p *ConnPool) Add(cn *Conn) bool

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

+ func (p *ConnPool) First() *Conn

+ func (p *ConnPool) FreeLen() int

+ func (p *ConnPool) Get() (cn *Conn, isNew bool, err error)

+ func (p *ConnPool) Len() int

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

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

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

+ func (p *ConnPool) Replace(cn *Conn, reason error) error

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

+ type PoolStats struct

+ FreeConns uint32

+ Hits uint32

+ Requests uint32

+ Timeouts uint32

+ TotalConns uint32

+ Waits uint32

+ type Pooler interface

+ Close func() error

+ First func() *Conn

+ FreeLen func() int

+ Get func() (*Conn, bool, error)

+ Len func() int

+ Put func(*Conn) error

+ Replace func(*Conn, error) error

+ Stats func() *PoolStats

+ type SingleConnPool struct

+ func NewSingleConnPool(cn *Conn) *SingleConnPool

+ func (p *SingleConnPool) Close() error

+ func (p *SingleConnPool) First() *Conn

+ func (p *SingleConnPool) FreeLen() int

+ func (p *SingleConnPool) Get() (*Conn, bool, error)

+ func (p *SingleConnPool) Len() int

+ func (p *SingleConnPool) Put(cn *Conn) error

+ func (p *SingleConnPool) Replace(cn *Conn, _ error) error

+ func (p *SingleConnPool) Stats() *PoolStats

+ type StickyConnPool struct

+ func NewStickyConnPool(pool *ConnPool, reusable bool) *StickyConnPool

+ func (p *StickyConnPool) Close() error

+ func (p *StickyConnPool) First() *Conn

+ func (p *StickyConnPool) FreeLen() int

+ func (p *StickyConnPool) Get() (cn *Conn, isNew bool, err error)

+ func (p *StickyConnPool) Len() int

+ func (p *StickyConnPool) Put(cn *Conn) error

+ func (p *StickyConnPool) Replace(cn *Conn, reason error) error

+ func (p *StickyConnPool) Stats() *PoolStats