Documentation
¶
Index ¶
- Constants
- Variables
- func InitRedisConn(conn goetty.IOSession)
- func NewRedisDecoder() goetty.Decoder
- func NewRedisReplyDecoder() goetty.Decoder
- func WriteArray(lst []interface{}, buf *goetty.ByteBuf)
- func WriteBulk(b []byte, buf *goetty.ByteBuf)
- func WriteCommand(conn goetty.IOSession, cmd string, args ...interface{}) error
- func WriteError(err []byte, buf *goetty.ByteBuf)
- func WriteFVPairArray(fvs [][]byte, buf *goetty.ByteBuf)
- func WriteInteger(n int64, buf *goetty.ByteBuf)
- func WriteScorePairArray(membersAndScores [][]byte, withScores bool, buf *goetty.ByteBuf)
- func WriteSliceArray(lst [][]byte, buf *goetty.ByteBuf)
- func WriteStatus(status []byte, buf *goetty.ByteBuf)
- type BulkResp
- type Command
- type ErrResp
- type IntegerResp
- type NullArrayResp
- type NullBulkResp
- type StatusResp
Constants ¶
View Source
const ( // CR \r CR = '\r' // LF \n LF = '\n' // ARGBegin '$' ARGBegin = '$' // CMDBegin '*' CMDBegin = '*' )
Variables ¶
View Source
var ( // Delims delims Delims = []byte("\r\n") // NullBulk empty bulk string NullBulk = []byte("-1") // NullArray empty array NullArray = []byte("0") )
Functions ¶
func NewRedisDecoder ¶
NewRedisDecoder returns a redis protocol decoder
func NewRedisReplyDecoder ¶
NewRedisReplyDecoder returns a redis protocol cmd reply decoder
func WriteArray ¶
WriteArray write array resp
func WriteCommand ¶
WriteCommand write redis command
func WriteFVPairArray ¶
WriteFVPairArray write field-value pair array resp
func WriteScorePairArray ¶
WriteScorePairArray write score-member pair array resp
func WriteSliceArray ¶
WriteSliceArray write slice array resp
func WriteStatus ¶
WriteStatus write status resp
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.