protocol

Documentation

Index

• Constants
• Variables
• func BulkString(val string) []byte
• func Error(val error) []byte
• func Nil() []byte
• func SimpleString(val string) []byte
• type Command
  • func ParseRequest(buf *bytes.Buffer) (*Command, error)
• type Executor
  • func NewExecutor(db Storage) *Executor
  • func (e *Executor) Echo(args []string) []byte
  • func (e *Executor) Execute(cmd *Command) []byte
  • func (e *Executor) Get(args []string) []byte
  • func (e *Executor) Ping(args []string) []byte
  • func (e *Executor) Set(args []string) []byte
• type Storage

Constants

const (
	CommandPing = "PING"
	CommandSet  = "SET"
	CommandGet  = "GET"
	CommandEcho = "ECHO"
)

const (
	RESPSimpleString = '+'
	RESPBulkString   = '$'
	RESPArray        = '*'
	RESPError        = '-'
)

Variables

var (
	ErrWrongNumberOfArguments = errors.New("ERR wrong number of arguments for command")
	ErrSyntax                 = errors.New("ERR syntax error")
)

var (
	CLRFBytes = []byte{'\r', '\n'}
)

Functions

func BulkString

func BulkString(val string) []byte

func Error

func Error(val error) []byte

func Nil

func Nil() []byte

func SimpleString

func SimpleString(val string) []byte

Types

type Command

type Command struct {
	Type string
	Args []string
}

func ParseRequest

func ParseRequest(buf *bytes.Buffer) (*Command, error)

type Executor

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

func NewExecutor

func NewExecutor(db Storage) *Executor

func (*Executor) Echo

func (e *Executor) Echo(args []string) []byte

func (*Executor) Execute

func (e *Executor) Execute(cmd *Command) []byte

func (*Executor) Get

func (e *Executor) Get(args []string) []byte

func (*Executor) Ping

func (e *Executor) Ping(args []string) []byte

func (*Executor) Set

func (e *Executor) Set(args []string) []byte

type Storage

type Storage interface {
	Set(string, any) error
	Get(string) (any, error)
}