redis

Documentation

Index

• Variables
• func NewNodeConn(cluster, addr string, dialTimeout, readTimeout, writeTimeout time.Duration) (nc proto.NodeConn)
• func NewPinger(conn *libnet.Conn) proto.Pinger
• func NewProxyConn(conn *libnet.Conn) proto.ProxyConn
• type Request
  • func (r *Request) Cmd() []byte
  • func (r *Request) CmdString() string
  • func (r *Request) Key() []byte
  • func (r *Request) Put()

Variables

var (
	ErrPingClosed = errors.New("ping interface has been closed")
	ErrBadPong    = errors.New("pong response payload is bad")
)

errors

var (
	ErrBadAssert  = errs.New("bad assert for redis")
	ErrBadCount   = errs.New("bad count number")
	ErrBadRequest = errs.New("bad request")
)

errors

Functions

func NewNodeConn

func NewNodeConn(cluster, addr string, dialTimeout, readTimeout, writeTimeout time.Duration) (nc proto.NodeConn)

NewNodeConn create the node conn from proxy to redis

func NewPinger

func NewPinger(conn *libnet.Conn) proto.Pinger

NewPinger new pinger.

func NewProxyConn

func NewProxyConn(conn *libnet.Conn) proto.ProxyConn

NewProxyConn creates new redis Encoder and Decoder.

Types

type Request

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

Request is the type of a complete redis command

func (*Request) Cmd

func (r *Request) Cmd() []byte

Cmd get the cmd

func (*Request) CmdString

func (r *Request) CmdString() string

CmdString get the cmd

func (*Request) Key

func (r *Request) Key() []byte

Key impl the proto.protoRequest and get the Key of redis

func (*Request) Put

func (r *Request) Put()

Put the resource back to pool