Documentation
¶
Overview ¶
The client is the primary interface for redis. You must first create a client with redis address for working.
c := NewClient("127.0.0.1:6380")
or
c := NewClient("127.0.0.1:6380",DialWriteTimeout(1024),DialPassword("1234"))
The most important function for client is Do function to send commands to remote server.
reply, err := c.Do("ping") reply, err := c.Do("set", "key", "value") reply, err := c.Do("get", "key")
Connection ¶
You can use an independent connection to send commands.
//get a connection conn, _ := c.Get() //connection send command conn.Do("ping")
Reply Helper ¶
You can use reply helper to convert a reply to a specific type.
exists, err := Bool(c.Do("exists", "key")) score, err := Int64(c.Do("zscore", "key", "member"))
Index ¶
- Variables
- func Bool(reply interface{}, err error) (bool, error)
- func Bytes(reply interface{}, err error) ([]byte, error)
- func Float64(reply interface{}, err error) (float64, error)
- func Int(reply interface{}, err error) (int, error)
- func Int64(reply interface{}, err error) (int64, error)
- func MultiBulk(reply interface{}, err error) ([]interface{}, error)
- func String(reply interface{}, err error) (string, error)
- func Strings(reply interface{}, err error) ([]string, error)
- func Uint64(reply interface{}, err error) (uint64, error)
- func Values(reply interface{}, err error) ([]interface{}, error)
- type Client
- type Conn
- func (c *Conn) Addr() (string, string, error)
- func (c *Conn) Close()
- func (c *Conn) Do(cmd string, args ...interface{}) (interface{}, error)
- func (c *Conn) DumpAndParse(parse func(io.Reader) error) error
- func (c *Conn) GetTotalReadSize() int64
- func (c *Conn) GetTotalWriteSize() int64
- func (c *Conn) LocalAddr() net.Addr
- func (c *Conn) Receive() (interface{}, error)
- func (c *Conn) ReceiveBulkTo(w io.Writer) error
- func (c *Conn) ReceiveRequest() ([][]byte, error)
- func (c *Conn) RemoteAddr() net.Addr
- func (c *Conn) Send(cmd string, args ...interface{}) error
- func (c *Conn) SendValue(v interface{}) error
- func (c *Conn) SetReadDeadline(t time.Time) error
- func (c *Conn) SetWriteDeadline(t time.Time) error
- type DataStorage
- type DialOption
- func DialConnectTimeout(d time.Duration) DialOption
- func DialKeepAlive(d time.Duration) DialOption
- func DialMaxIdelConns(i int) DialOption
- func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption
- func DialPassword(password string) DialOption
- func DialReadTimeout(d time.Duration) DialOption
- func DialTLSConfig(c *tls.Config) DialOption
- func DialTLSSkipVerify(skip bool) DialOption
- func DialUseTLS(useTLS bool) DialOption
- func DialWriteTimeout(d time.Duration) DialOption
- type Error
- type HandlesFunc
- type Options
- type PoolConn
- type RespReader
- type RespWriter
- func (resp *RespWriter) Flush() error
- func (resp *RespWriter) FlushArray(ay []interface{}) error
- func (resp *RespWriter) FlushBulk(b []byte) error
- func (resp *RespWriter) FlushError(e error) error
- func (resp *RespWriter) FlushInteger(n int64) error
- func (resp *RespWriter) FlushString(s string) error
- func (resp *RespWriter) WriteArray(ay []interface{}) error
- func (resp *RespWriter) WriteBulk(b []byte) error
- func (resp *RespWriter) WriteBytesArray(ay [][]byte) error
- func (resp *RespWriter) WriteCommand(cmd string, args ...interface{}) error
- func (resp *RespWriter) WriteError(e error) error
- func (resp *RespWriter) WriteInteger(n int64) error
- func (resp *RespWriter) WriteStr2BytesArray(ay []interface{}) error
- func (resp *RespWriter) WriteString(s string) error
- type VirtualServer
Constants ¶
This section is empty.
Variables ¶
var ( OkReply interface{} = "OK" PongReply interface{} = "PONG" NilReply interface{} = nil )
var ErrNil = errors.New("nil returned")
ErrNil indicates that a reply value is nil.
Functions ¶
func Bool ¶
Bool is a helper that converts a command reply to a boolean. If err is not equal to nil, then Bool returns false, err. Otherwise Bool converts the reply to boolean as follows:
Reply type Result integer value != 0, nil bulk string strconv.ParseBool(reply) nil false, ErrNil other false, error
func Bytes ¶
Bytes is a helper that converts a command reply to a slice of bytes. If err is not equal to nil, then Bytes returns nil, err. Otherwise Bytes converts the reply to a slice of bytes as follows:
Reply type Result bulk string reply, nil simple string []byte(reply), nil nil nil, ErrNil other nil, error
func Float64 ¶
Float64 is a helper that converts a command reply to 64 bit float. If err is not equal to nil, then Float64 returns 0, err. Otherwise, Float64 converts the reply to an int as follows:
Reply type Result bulk string parsed reply, nil nil 0, ErrNil other 0, error
func Int ¶
Int is a helper that converts a command reply to an integer. If err is not equal to nil, then Int returns 0, err. Otherwise, Int converts the reply to an int as follows:
Reply type Result integer int(reply), nil bulk string parsed reply, nil nil 0, ErrNil other 0, error
func Int64 ¶
Int64 is a helper that converts a command reply to 64 bit integer. If err is not equal to nil, then Int returns 0, err. Otherwise, Int64 converts the reply to an int64 as follows:
Reply type Result integer reply, nil bulk string parsed reply, nil nil 0, ErrNil other 0, error
func String ¶
String is a helper that converts a command reply to a string. If err is not equal to nil, then String returns "", err. Otherwise String converts the reply to a string as follows:
Reply type Result bulk string string(reply), nil simple string reply, nil nil "", ErrNil other "", error
func Strings ¶
Strings is a helper that converts an array command reply to a []string. If err is not equal to nil, then Strings returns nil, err. If one of the array items is not a bulk string or nil, then Strings returns an error.
func Uint64 ¶
Uint64 is a helper that converts a command reply to 64 bit integer. If err is not equal to nil, then Int returns 0, err. Otherwise, Int64 converts the reply to an int64 as follows:
Reply type Result integer reply, nil bulk string parsed reply, nil nil 0, ErrNil other 0, error
Types ¶
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
func (*Conn) GetTotalReadSize ¶
func (*Conn) GetTotalWriteSize ¶
func (*Conn) ReceiveBulkTo ¶
Receive RESP bulk string reply into writer w
func (*Conn) ReceiveRequest ¶
Receive RESP command request, must array of bulk stirng
func (*Conn) RemoteAddr ¶
type DataStorage ¶
type DialOption ¶
type DialOption struct {
// contains filtered or unexported fields
}
DialOption specifies an option for dialing a Redis server.
func DialConnectTimeout ¶
func DialConnectTimeout(d time.Duration) DialOption
DialConnectTimeout specifies the timeout for connecting to the Redis server when no DialNetDial option is specified.
func DialKeepAlive ¶
func DialKeepAlive(d time.Duration) DialOption
DialKeepAlive specifies the keep-alive period for TCP connections to the Redis server when no DialNetDial option is specified. If zero, keep-alives are not enabled. If no DialKeepAlive option is specified then the default of 5 minutes is used to ensure that half-closed TCP sessions are detected.
func DialMaxIdelConns ¶
func DialMaxIdelConns(i int) DialOption
func DialNetDial ¶
func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption
DialNetDial specifies a custom dial function for creating TCP connections, otherwise a net.Dialer customized via the other options is used. DialNetDial overrides DialConnectTimeout and DialKeepAlive.
func DialPassword ¶
func DialPassword(password string) DialOption
DialPassword specifies the password to use when connecting to the Redis server.
func DialReadTimeout ¶
func DialReadTimeout(d time.Duration) DialOption
DialReadTimeout specifies the timeout for reading a single command reply.
func DialTLSConfig ¶
func DialTLSConfig(c *tls.Config) DialOption
DialTLSConfig specifies the config to use when a TLS connection is dialed. Has no effect when not dialing a TLS connection.
func DialTLSSkipVerify ¶
func DialTLSSkipVerify(skip bool) DialOption
DialTLSSkipVerify disables server name verification when connecting over TLS. Has no effect when not dialing a TLS connection.
func DialUseTLS ¶
func DialUseTLS(useTLS bool) DialOption
DialUseTLS specifies whether TLS should be used when connecting to the server. This option is ignore by DialURL.
func DialWriteTimeout ¶
func DialWriteTimeout(d time.Duration) DialOption
DialWriteTimeout specifies the timeout for writing a single command.
type HandlesFunc ¶
type HandlesFunc = func(rWriter *RespWriter, req [][]byte) error
type Options ¶
type Options struct {
// contains filtered or unexported fields
}
func (*Options) SetMaxIdelConns ¶
func (*Options) SetPassword ¶
type RespReader ¶
type RespReader struct {
// contains filtered or unexported fields
}
func NewRespReader ¶
func NewRespReader(br *bufio.Reader) *RespReader
func (*RespReader) ParseBulkTo ¶
func (resp *RespReader) ParseBulkTo(w io.Writer) error
Parse bulk string and write it with writer w
func (*RespReader) ParseRequest ¶
func (resp *RespReader) ParseRequest() ([][]byte, error)
Parse client -> server command request, must be array of bulk strings
type RespWriter ¶
type RespWriter struct {
// contains filtered or unexported fields
}
func NewRespWriter ¶
func NewRespWriter(bw *bufio.Writer) *RespWriter
func (*RespWriter) Flush ¶
func (resp *RespWriter) Flush() error
func (*RespWriter) FlushArray ¶
func (resp *RespWriter) FlushArray(ay []interface{}) error
func (*RespWriter) FlushBulk ¶
func (resp *RespWriter) FlushBulk(b []byte) error
func (*RespWriter) FlushError ¶
func (resp *RespWriter) FlushError(e error) error
func (*RespWriter) FlushInteger ¶
func (resp *RespWriter) FlushInteger(n int64) error
func (*RespWriter) FlushString ¶
func (resp *RespWriter) FlushString(s string) error
func (*RespWriter) WriteArray ¶
func (resp *RespWriter) WriteArray(ay []interface{}) error
func (*RespWriter) WriteBulk ¶
func (resp *RespWriter) WriteBulk(b []byte) error
func (*RespWriter) WriteBytesArray ¶
func (resp *RespWriter) WriteBytesArray(ay [][]byte) error
func (*RespWriter) WriteCommand ¶
func (resp *RespWriter) WriteCommand(cmd string, args ...interface{}) error
RESP command is array of bulk string
func (*RespWriter) WriteError ¶
func (resp *RespWriter) WriteError(e error) error
func (*RespWriter) WriteInteger ¶
func (resp *RespWriter) WriteInteger(n int64) error
func (*RespWriter) WriteStr2BytesArray ¶
func (resp *RespWriter) WriteStr2BytesArray(ay []interface{}) error
func (*RespWriter) WriteString ¶
func (resp *RespWriter) WriteString(s string) error
type VirtualServer ¶
type VirtualServer struct { DataStorage // contains filtered or unexported fields }
func NewVirtualServer ¶
func NewVirtualServer(stge DataStorage) *VirtualServer
func (*VirtualServer) AddHandles ¶
func (v *VirtualServer) AddHandles(name string, h HandlesFunc)
func (*VirtualServer) Serve ¶
func (v *VirtualServer) Serve(addr string) (cancel func(), port string)