redis

Documentation

Index

• Constants
• Variables
• func FormatFloat64(s string) (float64, error)
• func FormatInt64(s string) (int64, error)
• func Serve(addr string, handler HandlerFunc) error
• type Command
• type Conn
• type HandlerFunc
• type Options
• type Reader
  • func NewReader(rd io.Reader) *Reader
  • func (r *Reader) ReadCommand() error
  • func (r *Reader) ReadInlineCommand() error
• type Writer
  • func NewWriter(w io.Writer) *Writer
  • func (w *Writer) Bytes() []byte
  • func (w *Writer) Flush() error
  • func (w *Writer) HasError() bool
  • func (w *Writer) RemoteAddr() string
  • func (w *Writer) WriteArray(l int)
  • func (w *Writer) WriteArrayNull()
  • func (w *Writer) WriteBulk(bulk string)
  • func (w *Writer) WriteBulkNull()
  • func (w *Writer) WriteDouble(v float64)
  • func (w *Writer) WriteError(err string)
  • func (w *Writer) WriteInt64(v int64)
  • func (w *Writer) WriteMap(n int)
  • func (w *Writer) WriteNullMap()
  • func (w *Writer) WriteOK()
  • func (w *Writer) WriteString(str string)
  • func (w *Writer) WriteUInt64(v uint64)

Constants

const (
	StringType  = '+'
	ErrType     = '-'
	IntegerType = ':'
	BulkType    = '$'
	ArrayType   = '*'
	MapType     = '%'
	DoubleType  = ','
	NullType    = '_'
)

const (
	MultiNone    uint8 = 0
	MultiPrepare uint8 = 1
	MultiCommit  uint8 = 2
	MultiError   uint8 = 4
)

Variables

var (
	ErrInvalidRequestExceptedArray       = errors.New("invalid request, expected array")
	ErrInvalidRequestExceptedArrayLength = errors.New("invalid request, expected array length")
	ErrInvalidRequestExceptedBulk        = errors.New("invalid request, expected bulk")
)

var ClientNum atomic.Int64

Functions

func FormatFloat64

func FormatFloat64(s string) (float64, error)

func FormatInt64

func FormatInt64(s string) (int64, error)

func Serve

func Serve(addr string, handler HandlerFunc) error

Types

type Command

type Command struct {
	Name    string
	Args    []string
	Options Options
}

type Conn

type Conn struct {
	*Reader
	*Writer
	Network   net.Conn
	Commands  []func()
	State     uint8
	WatchKeys btree.Map[string, bool]
}

type HandlerFunc

type HandlerFunc func(c *Conn, cmd Command)

type Options

type Options struct {
	NX         int
	XX         int
	KEEPTTL    int
	GET        int
	LT         int
	GT         int
	CH         int
	INCR       int
	WITHSCORES int
	EX         int
	PX         int
	EXAT       int
	PXAT       int
	MATCH      int
	COUNT      int
	BYLEX      int
	BYSCORE    int
	LIMIT      int
	BYTE       int
	BIT        int
	NUMKEYS    int
	WEIGHTS    int
	AGGREGATE  int
	REV        int
	TYPE       int
	M          int
	KM         int
	FT         int
	MI         int
	ASC        int
	DESC       int
	ANY        int
	WITHCOORD  int
	WITHDIST   int
	WITHHASH   int
}

type Reader

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

func NewReader

func NewReader(rd io.Reader) *Reader

func (*Reader) ReadCommand

func (r *Reader) ReadCommand() error

func (*Reader) ReadInlineCommand

func (r *Reader) ReadInlineCommand() error

type Writer

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

Writer is a RESP writer

func NewWriter

func NewWriter(w io.Writer) *Writer

func (*Writer) Bytes

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

func (*Writer) Flush

func (w *Writer) Flush() error

func (*Writer) HasError

func (w *Writer) HasError() bool

func (*Writer) RemoteAddr

func (w *Writer) RemoteAddr() string

func (*Writer) WriteArray

func (w *Writer) WriteArray(l int)

func (*Writer) WriteArrayNull

func (w *Writer) WriteArrayNull()

func (*Writer) WriteBulk

func (w *Writer) WriteBulk(bulk string)

func (*Writer) WriteBulkNull

func (w *Writer) WriteBulkNull()

func (*Writer) WriteDouble

func (w *Writer) WriteDouble(v float64)

func (*Writer) WriteError

func (w *Writer) WriteError(err string)

func (*Writer) WriteInt64

func (w *Writer) WriteInt64(v int64)

func (*Writer) WriteMap

func (w *Writer) WriteMap(n int)

func (*Writer) WriteNullMap

func (w *Writer) WriteNullMap()

func (*Writer) WriteOK

func (w *Writer) WriteOK()

func (*Writer) WriteString

func (w *Writer) WriteString(str string)

func (*Writer) WriteUInt64

func (w *Writer) WriteUInt64(v uint64)