xedis

package
v0.0.0-...-70491fa Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 20, 2017 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DeadlineExceeded = errors.New("context deadline exceeded")

Functions

func HelpInfo

func HelpInfo() string

Types

type CallerI

type CallerI interface {
	// Do sends a command to the server and returns the received reply.
	Do(command string, args ...interface{}) (*Reply, error)
	// contains filtered or unexported methods
}

type ClientBase

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

func (*ClientBase) Close

func (this *ClientBase) Close() error

func (*ClientBase) Dial

func (this *ClientBase) Dial(view, proto, transfer, address string) error

func (*ClientBase) Do

func (this *ClientBase) Do(command string, args ...interface{}) (reply *Reply, err error)

func (*ClientBase) Err

func (this *ClientBase) Err() error

type ClientPoolBase

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

func (*ClientPoolBase) Close

func (this *ClientPoolBase) Close() error

func (*ClientPoolBase) Dial

func (this *ClientPoolBase) Dial(view, proto, transfer string, nRepeated int, address []string) error

func (*ClientPoolBase) Do

func (this *ClientPoolBase) Do(command string, args ...interface{}) (*Reply, error)

func (*ClientPoolBase) Err

func (this *ClientPoolBase) Err() error

func (*ClientPoolBase) SetOption

func (this *ClientPoolBase) SetOption(dialFunc func(string, string, string, string, time.Duration) (Conn, error), reuse bool)

func (*ClientPoolBase) SetTimeout

func (this *ClientPoolBase) SetTimeout(dur time.Duration)

type ConnBase

type ConnBase interface {
	// Close closes the connection.
	Close() error

	// Err returns a non-nil value when the connection is not usable.
	Err() error

	// Do sends a command to the server and returns the received reply.
	Do(command string, args ...interface{}) (*Reply, error)
}

type ConnWrap

type ConnWrap struct {
	Addr string
	C    Conn
}

type PipelineBase

type PipelineBase struct {
	ClientBase
	// contains filtered or unexported fields
}

func (*PipelineBase) Close

func (this *PipelineBase) Close() error

func (*PipelineBase) Dial

func (this *PipelineBase) Dial(view, proto, transfer, address string) error

func (*PipelineBase) Do

func (this *PipelineBase) Do(command string, args ...interface{}) (reply *Reply, err error)

func (*PipelineBase) SetTimeout

func (this *PipelineBase) SetTimeout(dur time.Duration)

type PipelineContext

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

func (*PipelineContext) Done

func (this *PipelineContext) Done(r *Reply, err error)

type Reply

type Reply P.Reply

type ViewCommon

type ViewCommon struct {
	CallerI
}

func (*ViewCommon) Del

func (this *ViewCommon) Del(keys ...string) (n int64, err error)

func (*ViewCommon) FlushAll

func (this *ViewCommon) FlushAll() (err error)

func (*ViewCommon) Info

func (this *ViewCommon) Info() (s string, err error)

func (*ViewCommon) Seq

func (this *ViewCommon) Seq(key string) (seq int64, err error)

type ViewCommonI

type ViewCommonI interface {
	Del(keys ...string) (n int64, err error)
	FlushAll() (err error)
	Info() (s string, err error)
	Seq(key string) (seq int64, err error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL