resp

Documentation

Overview

RESP protocol models for requests and responses

Command processor handling the business logic for RESP. Accepts and returns a byte slice on the processing channel. It is not meant to be instanciated, hence no struct here.

Index

• Constants
• func StartCommandProcessor(requestChannel <-chan NetworkRequest, storage KVStorage)
• type KVStorage
• type NetworkRequest
• type RespCommand
• type RespExecRequest
• type RespFunc
• type RespRequest
• type RespResponse
• type ResponseDataType

Constants

const (
	DT_SIMPLE_STRING    = '+'
	DT_SIMPLE_ERROR     = '-'
	DT_INTEGER          = ':'
	DT_BULK_STRINGS     = '$'
	DT_ARRAYS           = '*'
	DT_NULLS            = '_'
	DT_BOOLEANS         = '#'
	DT_DOUBLES          = ','
	DT_BIG_NUMBERS      = '('
	DT_BULK_ERRORS      = '|'
	DT_VERBATIM_STRINGS = '='
	DT_MAPS             = '%'
	DT_SETS             = '~'
	DT_PUSHES           = '>'
)

const (
	RESP_OK  = "OK"
	RESP_ERR = "ERR"
)

Functions

func StartCommandProcessor

func StartCommandProcessor(requestChannel <-chan NetworkRequest, storage KVStorage)

Redis proccesses in a single thread. This "event loop" provides the same behaviour while offering concurrency for the incoming connections. It also means the storage does not have to worry about race conditions.

Types

type KVStorage

type KVStorage interface {
	Get(key string) storage.Entry
	Set(key string, value storage.Entry)
	Delete(key string)
}

Open up for different kinds of storage in the future

type NetworkRequest

type NetworkRequest struct {
	ResponseChannel chan<- []byte
	Data            []byte
}

Requests from the network layer now have their own ResponseChannels The internal types are still generic.

type RespCommand

type RespCommand string

const (
	RESP_GET  RespCommand = "GET"
	RESP_SET  RespCommand = "SET"
	RESP_INCR RespCommand = "INCR"
	RESP_DEL  RespCommand = "DEL"
)

type RespExecRequest

type RespExecRequest struct {
	ResponseChannel chan<- []byte
	// contains filtered or unexported fields
}

Actual execution of the validated commands are no offloaded to new goroutines.

type RespFunc

type RespFunc = func(request *RespRequest, kv KVStorage) (*RespResponse, error)

type RespRequest

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

type RespResponse

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

type ResponseDataType

type ResponseDataType byte