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 NodeConn
  • func (nc *NodeConn) Bw() *bufio.Writer
• type ProxyConn
  • func (pc *ProxyConn) Bw() *bufio.Writer
• type RESP
  • func (r *RESP) Array() []*RESP
  • func (r *RESP) Data() []byte
  • func (r *RESP) Decode(br *bufio.Reader) (err error)
  • func (r *RESP) Encode(w *bufio.Writer) (err error)
  • func (r *RESP) Type() byte
• type Request
  • func (r *Request) Cmd() []byte
  • func (r *Request) CmdString() string
  • func (r *Request) IsCtl() bool
  • func (r *Request) IsSupport() bool
  • func (r *Request) Key() []byte
  • func (r *Request) Put()
  • func (r *Request) RESP() *RESP
  • func (r *Request) Reply() *RESP

Variables

var (
	ErrPingClosed = errs.New("ping interface has been closed")
	ErrBadPong    = errs.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

var (
	// ErrNodeConnClosed err node conn closed.
	ErrNodeConnClosed = errs.New("redis node conn closed")
)

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 NodeConn

type NodeConn = nodeConn

NodeConn is export type by nodeConn for redis-cluster.

func (*NodeConn) Bw

func (nc *NodeConn) Bw() *bufio.Writer

Bw return bufio.Writer.

type ProxyConn

type ProxyConn = proxyConn

ProxyConn is export for redis cluster.

func (*ProxyConn) Bw

func (pc *ProxyConn) Bw() *bufio.Writer

Bw return proxyConn Writer.

type RESP

type RESP = resp

RESP is resp export type.

func (*RESP) Array

func (r *RESP) Array() []*RESP

Array return resp array.

func (*RESP) Data

func (r *RESP) Data() []byte

Data return resp data.

func (*RESP) Decode

func (r *RESP) Decode(br *bufio.Reader) (err error)

Decode decode by Reader.

func (*RESP) Encode

func (r *RESP) Encode(w *bufio.Writer) (err error)

Encode encode into Writer.

func (*RESP) Type

func (r *RESP) Type() byte

Type return resp type.

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) IsCtl

func (r *Request) IsCtl() bool

IsCtl is control command.

func (*Request) IsSupport

func (r *Request) IsSupport() bool

IsSupport check command support.

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

func (*Request) RESP

func (r *Request) RESP() *RESP

RESP return request resp.

func (*Request) Reply

func (r *Request) Reply() *RESP

Reply return request reply.