package proto

import "github.com/go-redis/redis/internal/proto"

Index ¶

• Constants
• func ParseErrorReply(line []byte) error
• func Scan(b []byte, v interface{}) error
• func ScanSlice(data []string, slice interface{}) error
• type MultiBulkParse
• type Reader
• func NewReader(rd io.Reader) *Reader
• func (r *Reader) ReadArrayLen() (int64, error)
• func (r *Reader) ReadArrayReply(m MultiBulkParse) (interface{}, error)
• func (r *Reader) ReadFloatReply() (float64, error)
• func (r *Reader) ReadInt() (int64, error)
• func (r *Reader) ReadIntReply() (int64, error)
• func (r *Reader) ReadLine() ([]byte, error)
• func (r *Reader) ReadReply(m MultiBulkParse) (interface{}, error)
• func (r *Reader) ReadScanReply() ([]string, uint64, error)
• func (r *Reader) ReadString() (string, error)
• func (r *Reader) ReadUint() (uint64, error)
• func (r *Reader) Reset(rd io.Reader)
• type RedisError
• func (e RedisError) Error() string
• type Writer
• func NewWriter(wr io.Writer) *Writer
• func (w *Writer) Flush() error
• func (w *Writer) Reset(wr io.Writer)
• func (w *Writer) WriteArgs(args []interface{}) error

Constants ¶

const (
	ErrorReply  = '-'
	StatusReply = '+'
	IntReply    = ':'
	StringReply = '$'
	ArrayReply  = '*'
)

const Nil = RedisError("redis: nil")

Functions ¶

func ParseErrorReply ¶

func ParseErrorReply(line []byte) error

func Scan ¶

func Scan(b []byte, v interface{}) error

func ScanSlice ¶

func ScanSlice(data []string, slice interface{}) error

Types ¶

type MultiBulkParse ¶

type MultiBulkParse func(*Reader, int64) (interface{}, error)

type Reader ¶

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

func NewReader ¶

func NewReader(rd io.Reader) *Reader

func (*Reader) ReadArrayLen ¶

func (r *Reader) ReadArrayLen() (int64, error)

func (*Reader) ReadArrayReply ¶

func (r *Reader) ReadArrayReply(m MultiBulkParse) (interface{}, error)

func (*Reader) ReadFloatReply ¶

func (r *Reader) ReadFloatReply() (float64, error)

func (*Reader) ReadInt ¶

func (r *Reader) ReadInt() (int64, error)

func (*Reader) ReadIntReply ¶

func (r *Reader) ReadIntReply() (int64, error)

func (*Reader) ReadLine ¶

func (r *Reader) ReadLine() ([]byte, error)

func (*Reader) ReadReply ¶

func (r *Reader) ReadReply(m MultiBulkParse) (interface{}, error)

func (*Reader) ReadScanReply ¶

func (r *Reader) ReadScanReply() ([]string, uint64, error)

func (*Reader) ReadString ¶

func (r *Reader) ReadString() (string, error)

func (*Reader) ReadUint ¶

func (r *Reader) ReadUint() (uint64, error)

func (*Reader) Reset ¶

func (r *Reader) Reset(rd io.Reader)

type RedisError ¶

type RedisError string

func (RedisError) Error ¶

func (e RedisError) Error() string

type Writer ¶

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

func NewWriter ¶

func NewWriter(wr io.Writer) *Writer

func (*Writer) Flush ¶

func (w *Writer) Flush() error

func (*Writer) Reset ¶

func (w *Writer) Reset(wr io.Writer)

func (*Writer) WriteArgs ¶

func (w *Writer) WriteArgs(args []interface{}) error

Source Files ¶

reader.go scan.go writer.go