redis

Documentation

Index

• Variables
• func Encode(w *bufio.Writer, r Resp) error
• func EncodeToBytes(r Resp) ([]byte, error)
• func EncodeToString(r Resp) (string, error)
• func MustEncode(w *bufio.Writer, r Resp)
• func MustEncodeToBytes(r Resp) []byte
• func MustHandlerTable(o interface{}) map[string]HandlerFunc
• func NewHandlerTable(o interface{}) (map[string]HandlerFunc, error)
• func ParseArgs(resp Resp) (cmd string, args [][]byte, err error)
• type Array
  • func NewArray() *Array
  • func (r *Array) Append(a Resp)
  • func (r *Array) AppendBulkBytes(b []byte)
  • func (r *Array) AppendError(err error)
  • func (r *Array) AppendInt(n int64)
  • func (r *Array) AppendString(s string)
  • func (r *Array) Type() RespType
• type BulkBytes
  • func NewBulkBytes(p []byte) *BulkBytes
  • func NewBulkBytesWithString(s string) *BulkBytes
  • func (r *BulkBytes) Type() RespType
• type Error
  • func NewError(err error) *Error
  • func NewErrorWithString(s string) *Error
  • func (r *Error) Type() RespType
• type HandlerFunc
• type HandlerTable
• type Int
  • func NewInt(n int64) *Int
  • func (r *Int) Type() RespType
• type Resp
  • func Decode(r *bufio.Reader) (Resp, error)
  • func DecodeFromBytes(p []byte) (Resp, error)
  • func MustDecode(r *bufio.Reader) Resp
  • func MustDecodeFromBytes(p []byte) Resp
• type RespType
  • func (t RespType) String() string
• type Server
  • func MustServer(o interface{}) *Server
  • func NewServer(o interface{}) (*Server, error)
  • func NewServerWithTable(t HandlerTable) (*Server, error)
  • func (s *Server) Dispatch(arg0 interface{}, resp Resp) (Resp, error)
• type String
  • func NewString(s string) *String
  • func (r *String) Type() RespType

Variables

var (
	ErrBadRespType     = errors.Static("bad resp type")
	ErrBadRespEnd      = errors.Static("bad resp end")
	ErrBadRespInt      = errors.Static("bad resp int")
	ErrBadRespBytesLen = errors.Static("bad resp bytes len")
	ErrBadRespArrayLen = errors.Static("bad resp array len")
)

Functions

func Encode

func Encode(w *bufio.Writer, r Resp) error

func EncodeToBytes

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

func EncodeToString

func EncodeToString(r Resp) (string, error)

func MustEncode

func MustEncode(w *bufio.Writer, r Resp)

func MustEncodeToBytes

func MustEncodeToBytes(r Resp) []byte

func MustHandlerTable

func MustHandlerTable(o interface{}) map[string]HandlerFunc

func NewHandlerTable

func NewHandlerTable(o interface{}) (map[string]HandlerFunc, error)

func ParseArgs

func ParseArgs(resp Resp) (cmd string, args [][]byte, err error)

Types

type Array

type Array struct {
	Value []Resp
}

func NewArray

func NewArray() *Array

func (*Array) Append

func (r *Array) Append(a Resp)

func (*Array) AppendBulkBytes

func (r *Array) AppendBulkBytes(b []byte)

func (*Array) AppendError

func (r *Array) AppendError(err error)

func (*Array) AppendInt

func (r *Array) AppendInt(n int64)

func (*Array) AppendString

func (r *Array) AppendString(s string)

func (*Array) Type

func (r *Array) Type() RespType

type BulkBytes

type BulkBytes struct {
	Value []byte
}

func NewBulkBytes

func NewBulkBytes(p []byte) *BulkBytes

func NewBulkBytesWithString

func NewBulkBytesWithString(s string) *BulkBytes

func (*BulkBytes) Type

func (r *BulkBytes) Type() RespType

type Error

type Error struct {
	Value string
}

func NewError

func NewError(err error) *Error

func NewErrorWithString

func NewErrorWithString(s string) *Error

func (*Error) Type

func (r *Error) Type() RespType

type HandlerFunc

type HandlerFunc func(arg0 interface{}, args ...[]byte) (Resp, error)

type HandlerTable

type HandlerTable map[string]HandlerFunc

type Int

type Int struct {
	Value int64
}

func NewInt

func NewInt(n int64) *Int

func (*Int) Type

func (r *Int) Type() RespType

type Resp

type Resp interface {
	Type() RespType
}

func Decode

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

func DecodeFromBytes

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

func MustDecode

func MustDecode(r *bufio.Reader) Resp

func MustDecodeFromBytes

func MustDecodeFromBytes(p []byte) Resp

type RespType

type RespType byte

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

func (RespType) String

func (t RespType) String() string

type Server

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

func MustServer

func MustServer(o interface{}) *Server

func NewServer

func NewServer(o interface{}) (*Server, error)

func NewServerWithTable

func NewServerWithTable(t HandlerTable) (*Server, error)

func (*Server) Dispatch

func (s *Server) Dispatch(arg0 interface{}, resp Resp) (Resp, error)

type String

type String struct {
	Value string
}

func NewString

func NewString(s string) *String

func (*String) Type

func (r *String) Type() RespType