redis

package module

Go to main page

Versions in this module

v1

v1.0.0

Aug 7, 2017

v0

v0.5.2

Nov 5, 2019

Changes in this version

type Server

+ AcceptCallBack func(conn *Conn) bool

+ ClosedCallBack func(conn *Conn, err error)

v0.5.1

Aug 7, 2017

Changes in this version

+ var ErrNilArgs = errors.New("cannot parse values from a nil argument list")

+ var ErrNotHijackable = errors.New("the response writer is not hijackable")

+ var ErrWriteStreamCalledAfterWrite = errors.New(...)

+ var ErrWriteStreamCalledTooManyTimes = errors.New("multiple calls to ResponseWriter.WriteStream")

type Client

+ func (c *Client) MultiExec(ctx context.Context, cmds ...Command) error

+ func (c *Client) MultiQuery(ctx context.Context, cmds ...Command) TxArgs

type Command

+ func (cmd *Command) ParseArgs(dsts ...interface{}) error

type Request

+ Cmds []Command

+ func (req *Request) Close() error

+ func (req *Request) IsTransaction() bool

type Response

+ TxArgs TxArgs

+ func (res *Response) Close() error

+ type ServerBlacklist interface

+ BlacklistServer func(ServerEndpoint)

v0.3.0

Jul 13, 2017

Changes in this version

+ var ErrDiscard = resp.NewError("EXECABORT Transcation discarded.")

+ type Command struct

+ Args Args

+ Cmd string

+ type CommandReader struct

+ func (r *CommandReader) Close() error

+ func (r *CommandReader) Read(cmd *Command) bool

+ type Conn struct

+ func Dial(network string, address string) (*Conn, error)

+ func DialContext(ctx context.Context, network string, address string) (*Conn, error)

+ func NewClientConn(conn net.Conn) *Conn

+ func NewServerConn(conn net.Conn) *Conn

+ func (c *Conn) Close() error

+ func (c *Conn) Flush() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) Read(b []byte) (int, error)

+ func (c *Conn) ReadArgs() Args

+ func (c *Conn) ReadCommands() *CommandReader

+ func (c *Conn) ReadTxArgs(n int) *TxArgs

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) Write(b []byte) (int, error)

+ func (c *Conn) WriteArgs(args Args) error

+ func (c *Conn) WriteCommands(cmds ...Command) error

type Transport

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ type TxArgs struct

+ func (tx *TxArgs) Close() error

+ func (tx *TxArgs) Len() int

+ func (tx *TxArgs) Next() Args

v0.2.0

Jul 11, 2017

Changes in this version

+ var DefaultClient = &Client

+ var DefaultDialer = &net.Dialer

+ var ErrHijacked = errors.New("invalid use of a hijacked redis.ResponseWriter")

+ var ErrNegativeStreamCount = errors.New("invalid call to redis.ResponseWriter.Stream with a negative value")

+ var ErrServerClosed = errors.New("redis: Server closed")

+ var ErrStreamCalledAfterWrite = errors.New(...)

+ var ErrStreamCalledTooManyTimes = errors.New("multiple calls to ResponseWriter.Stream")

+ var ErrWriteCalledNotEnoughTimes = errors.New("not enough calls to redis.ResponseWriter.Write")

+ var ErrWriteCalledTooManyTimes = errors.New("too many calls to redis.ResponseWriter.Write")

+ func Exec(ctx context.Context, cmd string, args ...interface{}) error

+ func Int(args Args) (i int, err error)

+ func Int64(args Args) (i int64, err error)

+ func ListenAndServe(addr string, handler Handler) error

+ func ParseArgs(args Args, dsts ...interface{}) error

+ func Serve(l net.Listener, handler Handler) error

+ func String(args Args) (s string, err error)

+ type Args interface

+ Close func() error

+ Len func() int

+ Next func(dst interface{}) bool

+ func List(args ...interface{}) Args

+ func MultiArgs(args ...Args) Args

+ func Query(ctx context.Context, cmd string, args ...interface{}) Args

+ type Client struct

+ Addr string

+ Timeout time.Duration

+ Transport RoundTripper

+ func (c *Client) Do(req *Request) (*Response, error)

+ func (c *Client) Exec(ctx context.Context, cmd string, args ...interface{}) error

+ func (c *Client) Query(ctx context.Context, cmd string, args ...interface{}) Args

+ type Flusher interface

+ Flush func() error

+ type Handler interface

+ ServeRedis func(ResponseWriter, *Request)

+ type HandlerFunc func(ResponseWriter, *Request)

+ func (f HandlerFunc) ServeRedis(res ResponseWriter, req *Request)

+ type Hijacker interface

+ Hijack func() (net.Conn, *bufio.ReadWriter, error)

+ type Request struct

+ Addr string

+ Args Args

+ Cmd string

+ Context context.Context

+ func NewRequest(addr string, cmd string, args Args) *Request

+ func (req *Request) ParseArgs(dsts ...interface{}) error

+ func (req *Request) Write(w io.Writer) error

+ type Response struct

+ Args Args

+ Request *Request

+ func (res *Response) Write(w io.Writer) error

+ type ResponseWriter interface

+ Write func(v interface{}) error

+ WriteStream func(n int) error

+ type ReverseProxy struct

+ ErrorLog *log.Logger

+ Registry ServerRegistry

+ Transport RoundTripper

+ func (proxy *ReverseProxy) ServeRedis(w ResponseWriter, r *Request)

+ type RoundTripper interface

+ RoundTrip func(*Request) (*Response, error)

+ var DefaultTransport RoundTripper = &Transport{ ... }

+ type Server struct

+ Addr string

+ ErrorLog *log.Logger

+ Handler Handler

+ IdleTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func (s *Server) Close() error

+ func (s *Server) ListenAndServe() error

+ func (s *Server) Serve(l net.Listener) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerEndpoint struct

+ Addr string

+ Name string

+ func (endpoint ServerEndpoint) LookupServers(ctx context.Context) ([]ServerEndpoint, error)

+ type ServerList []ServerEndpoint

+ func (list ServerList) LookupServers(ctx context.Context) ([]ServerEndpoint, error)

+ type ServerRegistry interface

+ LookupServers func(ctx context.Context) ([]ServerEndpoint, error)

+ type SubConn struct

+ func NewSubConn(conn net.Conn) *SubConn

+ func (sub *SubConn) Close() error

+ func (sub *SubConn) LocalAddr() net.Addr

+ func (sub *SubConn) ReadMessage() (channel string, message []byte, err error)

+ func (sub *SubConn) RemoteAddr() net.Addr

+ func (sub *SubConn) SetDeadline(t time.Time) error

+ func (sub *SubConn) SetReadDeadline(t time.Time) error

+ func (sub *SubConn) SetWriteDeadline(t time.Time) error

+ func (sub *SubConn) WriteCommand(command string, channels ...string) (err error)

+ type Transport struct

+ ConnsPerHost int

+ DialContext func(context.Context, string, string) (net.Conn, error)

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ func (t *Transport) CloseIdleConnections()

+ func (t *Transport) PSubscribe(ctx context.Context, network string, address string, patterns ...string) (*SubConn, error)

+ func (t *Transport) RoundTrip(req *Request) (*Response, error)

+ func (t *Transport) Subscribe(ctx context.Context, network string, address string, channels ...string) (*SubConn, error)

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