parser

Documentation

Index

• Constants
• func ParseStream(reader io.Reader) <-chan *Payload
• func SendProtocolError(ch chan<- *Payload, msg string)
• type Array
  • func NewArray(strs [][]byte) *Array
  • func (array *Array) Serialize() []byte
• type BulkString
  • func MakeNullBulkReply() *BulkString
  • func NewBulkString(data []byte) *BulkString
  • func (bs *BulkString) Serialize() []byte
• type Error
  • func NewError(data string) *Error
  • func (e *Error) Serialize() []byte
• type Integer
  • func NewInteger(num int64) *Integer
  • func (e *Integer) Serialize() []byte
• type Payload
• type RespData
• type String
  • func MakeOKReply() *String
  • func NewString(data string) *String
  • func (ss *String) Serialize() []byte

Constants

const (
	CRLF            = "\r\n"
	EmptyBulkString = "$-1" + CRLF
	PING            = "PING"
)

const (
	StringBegin     = '+'
	ErrorBegin      = '-'
	IntegerBegin    = ':'
	BulkStringBegin = '$'
	ArrayBegin      = '*'
)

Functions

func ParseStream

func ParseStream(reader io.Reader) <-chan *Payload

从reader中解析数据流成resp命令

func SendProtocolError

func SendProtocolError(ch chan<- *Payload, msg string)

Types

type Array

type Array struct {
	Args [][]byte
}

func NewArray

func NewArray(strs [][]byte) *Array

func (*Array) Serialize

func (array *Array) Serialize() []byte

type BulkString

type BulkString struct {
	Arg []byte
}

func MakeNullBulkReply

func MakeNullBulkReply() *BulkString

func NewBulkString

func NewBulkString(data []byte) *BulkString

func (*BulkString) Serialize

func (bs *BulkString) Serialize() []byte

type Error

type Error struct {
	Arg string
}

func NewError

func NewError(data string) *Error

func (*Error) Serialize

func (e *Error) Serialize() []byte

type Integer

type Integer struct {
	Arg int64
}

func NewInteger

func NewInteger(num int64) *Integer

func (*Integer) Serialize

func (e *Integer) Serialize() []byte

type Payload

type Payload struct {
	Data RespData
	Err  error
}

type RespData

type RespData interface {
	Serialize() []byte
}

type String

type String struct {
	Arg string
}

func MakeOKReply

func MakeOKReply() *String

func NewString

func NewString(data string) *String

func (*String) Serialize

func (ss *String) Serialize() []byte