package proto

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

Index ¶

• Constants
• func Scan(b []byte, val interface{}) error
• type MultiBulkParse
• type Reader
• func NewReader(rd io.Reader) *Reader
• func (p *Reader) PeekBuffered() []byte
• func (p *Reader) ReadArrayLen() (int64, error)
• func (p *Reader) ReadArrayReply(m MultiBulkParse) (interface{}, error)
• func (p *Reader) ReadBytesReply() ([]byte, error)
• func (p *Reader) ReadFloatReply() (float64, error)
• func (p *Reader) ReadIntReply() (int64, error)
• func (p *Reader) ReadLine() ([]byte, error)
• func (p *Reader) ReadN(n int) ([]byte, error)
• func (p *Reader) ReadReply(m MultiBulkParse) (interface{}, error)
• func (p *Reader) ReadScanReply() ([]string, uint64, error)
• func (p *Reader) ReadStringReply() (string, error)
• type WriteBuffer
• func NewWriteBuffer() *WriteBuffer
• func (w *WriteBuffer) Append(args []interface{}) error
• func (w *WriteBuffer) AppendBytes(p []byte)
• func (w *WriteBuffer) AppendString(s string)
• func (w *WriteBuffer) Bytes() []byte
• func (w *WriteBuffer) Len() int
• func (w *WriteBuffer) Reset()

Constants ¶

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

Functions ¶

func Scan ¶

func Scan(b []byte, val 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) PeekBuffered ¶

func (p *Reader) PeekBuffered() []byte

func (*Reader) ReadArrayLen ¶

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

func (*Reader) ReadArrayReply ¶

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

func (*Reader) ReadBytesReply ¶

func (p *Reader) ReadBytesReply() ([]byte, error)

func (*Reader) ReadFloatReply ¶

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

func (*Reader) ReadIntReply ¶

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

func (*Reader) ReadLine ¶

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

func (*Reader) ReadN ¶

func (p *Reader) ReadN(n int) ([]byte, error)

func (*Reader) ReadReply ¶

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

func (*Reader) ReadScanReply ¶

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

func (*Reader) ReadStringReply ¶

func (p *Reader) ReadStringReply() (string, error)

type WriteBuffer ¶

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

func NewWriteBuffer ¶

func NewWriteBuffer() *WriteBuffer

func (*WriteBuffer) Append ¶

func (w *WriteBuffer) Append(args []interface{}) error

func (*WriteBuffer) AppendBytes ¶

func (w *WriteBuffer) AppendBytes(p []byte)

func (*WriteBuffer) AppendString ¶

func (w *WriteBuffer) AppendString(s string)

func (*WriteBuffer) Bytes ¶

func (w *WriteBuffer) Bytes() []byte

func (*WriteBuffer) Len ¶

func (w *WriteBuffer) Len() int

func (*WriteBuffer) Reset ¶

func (w *WriteBuffer) Reset()

Source Files ¶

proto.go reader.go writebuffer.go