redisconn

Documentation

Index

• Constants
• type Conn
  • func NewConnection(addr string, netTimeout int) (*Conn, error)
  • func NewConnectionWithSize(addr string, netTimeout int, readSize int, writeSize int) (*Conn, error)
  • func (c *Conn) BufioReader() *bufio.Reader
  • func (c *Conn) Close()
  • func (c *Conn) Flush() error
  • func (c *Conn) Read(p []byte) (int, error)
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetWriteDeadline(t time.Time) error
  • func (c *Conn) Write(p []byte) (int, error)
• type CreateConnFunc
• type Pool
  • func NewPool(addr string, capability int, f CreateConnFunc) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) GetConn() (*Conn, error)
  • func (p *Pool) PutConn(c *Conn)
• type Pools
  • func NewPools(capability int, f CreateConnFunc) *Pools
  • func (p *Pools) Close()
  • func (p *Pools) GetConn(addr string) (*Conn, error)
  • func (p *Pools) PutConn(c *Conn)

Constants

const (
	DefaultBufSize = 4 * 1024
)

const PoolIdleTimeoutSecond = 120

Types

type Conn

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

not thread-safe

func NewConnection

func NewConnection(addr string, netTimeout int) (*Conn, error)

func NewConnectionWithSize

func NewConnectionWithSize(addr string, netTimeout int, readSize int, writeSize int) (*Conn, error)

func (*Conn) BufioReader

func (c *Conn) BufioReader() *bufio.Reader

func (*Conn) Close

func (c *Conn) Close()

func (*Conn) Flush

func (c *Conn) Flush() error

func (*Conn) Read

func (c *Conn) Read(p []byte) (int, error)

require read to use bufio

func (*Conn) SetDeadline

func (c *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (c *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetWriteDeadline

func (c *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) Write

func (c *Conn) Write(p []byte) (int, error)

type CreateConnFunc

type CreateConnFunc func(addr string) (*Conn, error)

type Pool

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

func NewPool

func NewPool(addr string, capability int, f CreateConnFunc) *Pool

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) GetConn

func (p *Pool) GetConn() (*Conn, error)

func (*Pool) PutConn

func (p *Pool) PutConn(c *Conn)

type Pools

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

func NewPools

func NewPools(capability int, f CreateConnFunc) *Pools

func (*Pools) Close

func (p *Pools) Close()

func (*Pools) GetConn

func (p *Pools) GetConn(addr string) (*Conn, error)

func (*Pools) PutConn

func (p *Pools) PutConn(c *Conn)