Documentation ¶
Index ¶
- Variables
- type Conn
- type ConnPool
- func (p *ConnPool) Add(cn *Conn) bool
- func (p *ConnPool) Close() (retErr error)
- func (p *ConnPool) Closed() bool
- 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
- type Pooler
- type SingleConnPool
- func (p *SingleConnPool) Close() error
- func (p *SingleConnPool) Closed() bool
- 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
- func (p *StickyConnPool) Close() error
- func (p *StickyConnPool) Closed() bool
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrClosed = errors.New("redis: client is closed") ErrPoolTimeout = errors.New("redis: connection pool timeout") )
View Source
var Logger *log.Logger
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn struct { NetConn net.Conn Rd *bufio.Reader Buf []byte UsedAt time.Time ReadTimeout time.Duration WriteTimeout time.Duration // contains filtered or unexported fields }
func (*Conn) RemoteAddr ¶
type ConnPool ¶
type ConnPool struct { DialLimiter *ratelimit.RateLimiter // contains filtered or unexported fields }
func NewConnPool ¶
func (*ConnPool) First ¶
First returns first non-idle connection from the pool or nil if there are no connections.
func (*ConnPool) ReapStaleConns ¶
type PoolStats ¶
type PoolStats 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 Waits uint32 // number of times the pool had to wait for a connection 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 }
PoolStats contains pool state information and accumulated stats.
type SingleConnPool ¶
type SingleConnPool struct {
// contains filtered or unexported fields
}
func NewSingleConnPool ¶
func NewSingleConnPool(cn *Conn) *SingleConnPool
func (*SingleConnPool) Close ¶
func (p *SingleConnPool) Close() error
func (*SingleConnPool) Closed ¶
func (p *SingleConnPool) Closed() bool
func (*SingleConnPool) First ¶
func (p *SingleConnPool) First() *Conn
func (*SingleConnPool) FreeLen ¶
func (p *SingleConnPool) FreeLen() int
func (*SingleConnPool) Len ¶
func (p *SingleConnPool) Len() int
func (*SingleConnPool) Put ¶
func (p *SingleConnPool) Put(cn *Conn) error
func (*SingleConnPool) Stats ¶
func (p *SingleConnPool) Stats() *PoolStats
type StickyConnPool ¶
type StickyConnPool struct {
// contains filtered or unexported fields
}
func NewStickyConnPool ¶
func NewStickyConnPool(pool *ConnPool, reusable bool) *StickyConnPool
func (*StickyConnPool) Close ¶
func (p *StickyConnPool) Close() error
func (*StickyConnPool) Closed ¶
func (p *StickyConnPool) Closed() bool
func (*StickyConnPool) First ¶
func (p *StickyConnPool) First() *Conn
func (*StickyConnPool) FreeLen ¶
func (p *StickyConnPool) FreeLen() int
func (*StickyConnPool) Len ¶
func (p *StickyConnPool) Len() int
func (*StickyConnPool) Put ¶
func (p *StickyConnPool) Put(cn *Conn) error
func (*StickyConnPool) Stats ¶
func (p *StickyConnPool) Stats() *PoolStats
Click to show internal directories.
Click to hide internal directories.