redis

package

v0.0.0-...-de897e3 Latest Latest Go to latest Published: Aug 8, 2015 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kmiku7/codis-annotated

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Encode(bw *bufio.Writer, r *Resp, flush bool) error
func EncodeToBytes(r *Resp) ([]byte, error)
func IsTimeout(err error) bool
type Conn
- func (c *Conn) Close() error
type Decoder
- func NewDecoder(br *bufio.Reader) *Decoder
- func NewDecoderSize(r io.Reader, size int) *Decoder
- func (d *Decoder) Decode() (*Resp, error)
type Encoder
- func NewEncoder(bw *bufio.Writer) *Encoder
- func NewEncoderSize(w io.Writer, size int) *Encoder
- func (e *Encoder) Encode(r *Resp, flush bool) error
type Resp
type RespType
- func (t RespType) String() string

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrBadRespCRLFEnd  = errors.New("bad resp CRLF end")
	ErrBadRespBytesLen = errors.New("bad resp bytes len")
	ErrBadRespArrayLen = errors.New("bad resp array len")
)

Functions ¶

func Encode ¶

func Encode(bw *bufio.Writer, r *Resp, flush bool) error

func EncodeToBytes ¶

func EncodeToBytes(r *Resp) ([]byte, error)

func IsTimeout ¶

func IsTimeout(err error) bool

Types ¶

type Conn ¶

type Conn struct {
	Sock net.Conn

	// 这两个超时时间的设置见 router/session.go, NewSessionSize()
	ReaderTimeout time.Duration
	WriterTimeout time.Duration

	// 这两个是指针, 何时赋值初始化, 对Sock的包装,
	// 默认 bufsize 为64k.
	Reader *Decoder
	Writer *Encoder
}

封装关系循环引用了 Conn <- Decoder <- connReader <- Conn

func DialTimeout ¶

func DialTimeout(addr string, bufsize int, timeout time.Duration) (*Conn, error)

func NewConn ¶

func NewConn(sock net.Conn) *Conn

func NewConnSize ¶

func NewConnSize(sock net.Conn, bufsize int) *Conn

func (*Conn) Close ¶

func (c *Conn) Close() error

type Decoder ¶

type Decoder struct {
	*bufio.Reader

	Err error
}

func NewDecoder ¶

func NewDecoder(br *bufio.Reader) *Decoder

func NewDecoderSize ¶

func NewDecoderSize(r io.Reader, size int) *Decoder

这是bufio的size

func (*Decoder) Decode ¶

func (d *Decoder) Decode() (*Resp, error)

type Encoder ¶

type Encoder struct {
	*bufio.Writer

	Err error
}

func NewEncoder ¶

func NewEncoder(bw *bufio.Writer) *Encoder

func NewEncoderSize ¶

func NewEncoderSize(w io.Writer, size int) *Encoder

size 是bufio的大小

func (*Encoder) Encode ¶

func (e *Encoder) Encode(r *Resp, flush bool) error

type Resp ¶

type Resp struct {
	Type RespType

	Value []byte
	Array []*Resp
}

func Decode ¶

func Decode(br *bufio.Reader) (*Resp, error)

func DecodeFromBytes ¶

func DecodeFromBytes(p []byte) (*Resp, error)

func NewArray ¶

func NewArray(array []*Resp) *Resp

func NewBulkBytes ¶

func NewBulkBytes(value []byte) *Resp

func NewError ¶

func NewError(value []byte) *Resp

func NewInt ¶

func NewInt(value []byte) *Resp

func NewString ¶

func NewString(value []byte) *Resp

func (*Resp) Append ¶

func (r *Resp) Append(x *Resp)

func (*Resp) IsArray ¶

func (r *Resp) IsArray() bool

func (*Resp) IsBulkBytes ¶

func (r *Resp) IsBulkBytes() bool

func (*Resp) IsError ¶

func (r *Resp) IsError() bool

func (*Resp) IsInt ¶

func (r *Resp) IsInt() bool

func (*Resp) IsString ¶

func (r *Resp) IsString() bool

type RespType ¶

type RespType byte

const (
	TypeString    RespType = '+'
	TypeError     RespType = '-'
	TypeInt       RespType = ':'
	TypeBulkBytes RespType = '$'
	TypeArray     RespType = '*'
)

func (RespType) String ¶

func (t RespType) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL