redis

package

v1.1.1 Latest Latest Go to latest Published: Oct 13, 2016 License: MIT Imports: 9 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/CodisLabs/redis-port

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AsBulkBytes(r Resp, err error) ([]byte, error)
func AsError(r Resp, err error) (string, error)
func AsInt(r Resp, err error) (int64, error)
func AsString(r Resp, err error) (string, error)
func Encode(w *bufio.Writer, r Resp, flush bool) 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)
type BulkBytes
- func NewBulkBytes(p []byte) *BulkBytes
type Error
- func NewError(err error) *Error
type HandlerFunc
type HandlerTable
type Int
- func NewInt(n int64) *Int
type Resp
- func AsArray(r Resp, err error) ([]Resp, error)
- func Decode(r *bufio.Reader) (Resp, error)
- func DecodeFromBytes(p []byte) (Resp, error)
- func MustDecode(r *bufio.Reader) Resp
- func MustDecodeFromBytes(p []byte) Resp
- func NewCommand(cmd string, args ...interface{}) Resp
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

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrBadRespCRLFEnd  = errors.New("bad resp CRLF end")
	ErrBadRespBytesLen = errors.New("bad resp bytes len")
	ErrBadRespArrayLen = errors.New("bad resp array len")
)

Functions ¶

func AsBulkBytes ¶

func AsBulkBytes(r Resp, err error) ([]byte, error)

func AsError ¶

func AsError(r Resp, err error) (string, error)

func AsInt ¶

func AsInt(r Resp, err error) (int64, error)

func AsString ¶

func AsString(r Resp, err error) (string, error)

func Encode ¶

func Encode(w *bufio.Writer, r Resp, flush bool) 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)

type BulkBytes ¶

type BulkBytes struct {
	Value []byte
}

func NewBulkBytes ¶

func NewBulkBytes(p []byte) *BulkBytes

type Error ¶

type Error struct {
	Value string
}

func NewError ¶

func NewError(err error) *Error

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

type Resp ¶

type Resp interface {
}

func AsArray ¶

func AsArray(r Resp, err error) ([]Resp, error)

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

func NewCommand ¶

func NewCommand(cmd string, args ...interface{}) Resp

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL