Versions in this module Expand all Collapse all v1 v1.8.5 Sep 10, 2019 Changes in this version + var ErrNil = errors.New("redigo: nil returned") + var ErrPoolExhausted = errors.New("redigo: connection pool exhausted") + func Bool(reply interface{}, err error) (bool, error) + func ByteSlices(reply interface{}, err error) ([][]byte, error) + func Bytes(reply interface{}, err error) ([]byte, error) + func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error) + func Float64(reply interface{}, err error) (float64, error) + func Float64s(reply interface{}, err error) ([]float64, error) + func Int(reply interface{}, err error) (int, error) + func Int64(reply interface{}, err error) (int64, error) + func Int64Map(result interface{}, err error) (map[string]int64, error) + func Int64s(reply interface{}, err error) ([]int64, error) + func IntMap(result interface{}, err error) (map[string]int, error) + func Ints(reply interface{}, err error) ([]int, error) + func MultiBulk(reply interface{}, err error) ([]interface{}, error) + func Positions(result interface{}, err error) ([]*[2]float64, error) + func ReceiveWithTimeout(c Conn, timeout time.Duration) (interface{}, error) + func Scan(src []interface{}, dest ...interface{}) ([]interface{}, error) + func ScanSlice(src []interface{}, dest interface{}, fieldNames ...string) error + func ScanStruct(src []interface{}, dest interface{}) error + func String(reply interface{}, err error) (string, error) + func StringMap(result interface{}, err error) (map[string]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 Args []interface + func (args Args) Add(value ...interface{}) Args + func (args Args) AddFlat(v interface{}) Args + type Argument interface + RedisArg func() interface{} + type Conn interface + Close func() error + Do func(commandName string, args ...interface{}) (reply interface{}, err error) + Err func() error + Flush func() error + Receive func() (reply interface{}, err error) + Send func(commandName string, args ...interface{}) error + func Dial(network, address string, options ...DialOption) (Conn, error) + func DialTimeout(network, address string, ...) (Conn, error) + func DialURL(rawurl string, options ...DialOption) (Conn, error) + func NewConn(netConn net.Conn, readTimeout, writeTimeout time.Duration) Conn + func NewLoggingConn(conn Conn, logger *log.Logger, prefix string) Conn + type ConnWithTimeout interface + DoWithTimeout func(timeout time.Duration, commandName string, args ...interface{}) (reply interface{}, err error) + ReceiveWithTimeout func(timeout time.Duration) (reply interface{}, err error) + type DialOption struct + func DialConnectTimeout(d time.Duration) DialOption + func DialDatabase(db int) DialOption + func DialKeepAlive(d time.Duration) 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 string + func (err Error) Error() string + type Message struct + Channel string + Data []byte + Pattern string + type Pong struct + Data string + type Pool struct + Dial func() (Conn, error) + IdleTimeout time.Duration + MaxActive int + MaxConnLifetime time.Duration + MaxIdle int + TestOnBorrow func(c Conn, t time.Time) error + Wait bool + func NewPool(newFn func() (Conn, error), maxIdle int) *Pool + func (p *Pool) ActiveCount() int + func (p *Pool) Close() error + func (p *Pool) Get() Conn + func (p *Pool) GetContext(ctx context.Context) (Conn, error) + func (p *Pool) IdleCount() int + func (p *Pool) Stats() PoolStats + type PoolStats struct + ActiveCount int + IdleCount int + type PubSubConn struct + Conn Conn + func (c PubSubConn) Close() error + func (c PubSubConn) PSubscribe(channel ...interface{}) error + func (c PubSubConn) PUnsubscribe(channel ...interface{}) error + func (c PubSubConn) Ping(data string) error + func (c PubSubConn) Receive() interface{} + func (c PubSubConn) ReceiveWithTimeout(timeout time.Duration) interface{} + func (c PubSubConn) Subscribe(channel ...interface{}) error + func (c PubSubConn) Unsubscribe(channel ...interface{}) error + type Scanner interface + RedisScan func(src interface{}) error + type Script struct + func NewScript(keyCount int, src string) *Script + func (s *Script) Do(c Conn, keysAndArgs ...interface{}) (interface{}, error) + func (s *Script) Hash() string + func (s *Script) Load(c Conn) error + func (s *Script) Send(c Conn, keysAndArgs ...interface{}) error + func (s *Script) SendHash(c Conn, keysAndArgs ...interface{}) error + type Subscription struct + Channel string + Count int + Kind string
Go to main page