redis

Documentation

Index

• func ReadResp(r Reader) (any, error)
• type Command
• type Reader
• type RespArray
  • func (r *RespArray) RespType() RespType
• type RespError
  • func (r *RespError) RespType() RespType
• type RespInteger
  • func (r *RespInteger) RespType() RespType
• type RespString
  • func (r *RespString) RespType() RespType
• type RespType
• type Service
  • func NewService(context context.Context, logger hclog.Logger, addr string) *Service
  • func (s *Service) Start() error
  • func (s *Service) Stop() error

Functions

func ReadResp

func ReadResp(r Reader) (any, error)

Types

type Command

type Command interface {
}

type Reader

type Reader interface {
	Next(n int) (p []byte, err error)
	Peek(n int) (buf []byte, err error)
	Skip(n int) (err error)
}

type RespArray

type RespArray struct {
	Elements []any
	// contains filtered or unexported fields
}

func (*RespArray) RespType

func (r *RespArray) RespType() RespType

type RespError

type RespError struct {
	Message string
	// contains filtered or unexported fields
}

func (*RespError) RespType

func (r *RespError) RespType() RespType

type RespInteger

type RespInteger struct {
	Value int
	// contains filtered or unexported fields
}

func (*RespInteger) RespType

func (r *RespInteger) RespType() RespType

type RespString

type RespString struct {
	Data []byte
	// contains filtered or unexported fields
}

func (*RespString) RespType

func (r *RespString) RespType() RespType

type RespType

type RespType byte

const (
	RespTypeInteger      RespType = ':'
	RespTypeSimpleString RespType = '+'
	RespTypeBulkString   RespType = '$'
	RespTypeArray        RespType = '*'
	RespTypeError        RespType = '-'
)

type Service

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

func NewService

func NewService(context context.Context, logger hclog.Logger, addr string) *Service

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error