client

Documentation

Index

• func ArrayString(replyInterface interface{}, err error) ([]string, error)
• func EncodeArgv(argv []string, buf *bytes.Buffer)
• func Int64(reply interface{}, err error) (int64, error)
• func String(reply interface{}, err error) (string, error)
• type Redis
  • func NewRedisClient(address string, username string, password string, isTls bool) (*Redis, error)
  • func (r *Redis) BufioReader() *bufio.Reader
  • func (r *Redis) DoWithReply(args ...string) (interface{}, error)
  • func (r *Redis) DoWithStringReply(args ...string) (string, error)
  • func (r *Redis) Receive() (interface{}, error)
  • func (r *Redis) Scan(cursor uint64) (newCursor uint64, keys []string, err error)
  • func (r *Redis) Send(args ...string) error
  • func (r *Redis) SendBytes(buf []byte) error
  • func (r *Redis) SetBufioReader(rd *bufio.Reader)

Functions

func ArrayString

func ArrayString(replyInterface interface{}, err error) ([]string, error)

func EncodeArgv

func EncodeArgv(argv []string, buf *bytes.Buffer)

func Int64

func Int64(reply interface{}, err error) (int64, error)

func String

func String(reply interface{}, err error) (string, error)

Types

type Redis

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

func NewRedisClient

func NewRedisClient(address string, username string, password string, isTls bool) (*Redis, error)

func (*Redis) BufioReader

func (r *Redis) BufioReader() *bufio.Reader

func (*Redis) DoWithReply

func (r *Redis) DoWithReply(args ...string) (interface{}, error)

func (*Redis) DoWithStringReply

func (r *Redis) DoWithStringReply(args ...string) (string, error)

func (*Redis) Receive

func (r *Redis) Receive() (interface{}, error)

func (*Redis) Scan

func (r *Redis) Scan(cursor uint64) (newCursor uint64, keys []string, err error)

func (*Redis) Send

func (r *Redis) Send(args ...string) error

func (*Redis) SendBytes

func (r *Redis) SendBytes(buf []byte) error

func (*Redis) SetBufioReader

func (r *Redis) SetBufioReader(rd *bufio.Reader)