proxy

Documentation

Index

• Constants
• Variables
• func New(cfg *Config, scope *stats.Scope) (*proxy, error)
• type Config
• type Reader
  • func NewReader(rd io.Reader) *Reader
  • func NewReaderSize(rd io.Reader, size int) *Reader
  • func (b *Reader) PeekByte() (byte, error)
  • func (b *Reader) Read(p []byte) (int, error)
  • func (b *Reader) ReadByte() (byte, error)
  • func (b *Reader) ReadBytes(delim byte) ([]byte, error)
  • func (b *Reader) ReadFull(n int) ([]byte, error)
  • func (b *Reader) ReadSlice(delim byte) ([]byte, error)
• type RespType
• type RespValue

Constants

const (
	CR byte = '\r'
	LF byte = '\n'
)

const (
	ASKING      = "asking"
	MOVED       = "moved"
	ASK         = "ask"
	CLUSTERDOWN = "clusterdown"
)

Variables

var (
	// ErrBadRespType represents bad resp type
	ErrBadRespType = errors.New("bad resp type")

	// ErrBadCRLFEnd for invalid crlf
	ErrBadCRLFEnd = errors.New("bad CRLF end")

	// ErrBadArrayLen for invalid array len
	ErrBadArrayLen = errors.New("bad array len")
	// ErrBadArrayLenTooLong too long array len
	ErrBadArrayLenTooLong = errors.New("bad array len, too long")

	// ErrBadBulkStringLen for invalid bulk string len
	ErrBadBulkStringLen = errors.New("bad bulk string len")
	// ErrBadBulkStringLenTooLong for too long bulk string len
	ErrBadBulkStringLenTooLong = errors.New("bad bulk string len, too long")

	// ErrBadMultiBulkLen for invalid multi-bulk len
	ErrBadMultiBulkLen = errors.New("bad multi-bulk len")
	// ErrBadMultiBulkContent for invalid multi-bulk content
	ErrBadMultiBulkContent = errors.New("bad multi-bulk content, should be bulkbytes")
)

var CRLF = []byte{CR, LF}

crlf is the delimter in redis protocol.

Functions

func New

func New(cfg *Config, scope *stats.Scope) (*proxy, error)

Types

type Config

type Config struct {
	Bind  int
	Hosts []string
}

type Reader

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

Reader implements Reader for buffer

func NewReader

func NewReader(rd io.Reader) *Reader

NewReader creates Reader

func NewReaderSize

func NewReaderSize(rd io.Reader, size int) *Reader

NewReaderSize creates Reader with buffer size

func (*Reader) PeekByte

func (b *Reader) PeekByte() (byte, error)

PeekByte returns a single byte but does not consume

func (*Reader) Read

func (b *Reader) Read(p []byte) (int, error)

func (*Reader) ReadByte

func (b *Reader) ReadByte() (byte, error)

ReadByte reads a single byte

func (*Reader) ReadBytes

func (b *Reader) ReadBytes(delim byte) ([]byte, error)

ReadBytes reads bytes until a delimiter

func (*Reader) ReadFull

func (b *Reader) ReadFull(n int) ([]byte, error)

ReadFull reads n bytes

func (*Reader) ReadSlice

func (b *Reader) ReadSlice(delim byte) ([]byte, error)

ReadSlice reads a slice until a delimiter

type RespType

type RespType byte

const (
	SimpleString RespType = '+'
	Error        RespType = '-'
	Integer      RespType = ':'
	BulkString   RespType = '$'
	Array        RespType = '*'
)

type RespValue

type RespValue struct {
	Type RespType

	Int   int64
	Text  []byte
	Array []RespValue
}