redis

package

Go to main page

Versions in this module

v1

deprecated

v1.6.4

Aug 31, 2022

v1.6.3

Nov 6, 2021

v1.6.2

Apr 4, 2018

Changes in this version

type Pool

+ MaxConnLifetime time.Duration

v1.6.1-Deprecated-please-use-github-dot-com-gomodule-redigo

Apr 4, 2018

v1.6.0

Feb 28, 2018

Changes in this version

type Pool

+ func (p *Pool) GetContext(ctx context.Context) (Conn, error)

v1.5.0

Dec 29, 2017

v1.4.0

Dec 29, 2017

Changes in this version

+ func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error)

+ func ReceiveWithTimeout(c Conn, timeout time.Duration) (interface{}, error)

+ 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

+ func DialKeepAlive(d time.Duration) DialOption

type PubSubConn

+ func (c PubSubConn) ReceiveWithTimeout(timeout time.Duration) interface{}

v1.3.0

Nov 2, 2017

Changes in this version

+ func Float64s(reply interface{}, err error) ([]float64, error)

+ func Int64s(reply interface{}, err error) ([]int64, error)

v1.2.0

Oct 9, 2017

Changes in this version

+ type Argument interface

+ RedisArg func() interface{}

type DialOption

+ func DialUseTLS(useTLS bool) DialOption

type Pool

+ func (p *Pool) IdleCount() int

+ func (p *Pool) Stats() PoolStats

+ type PoolStats struct

+ ActiveCount int

+ IdleCount int

+ type Scanner interface

+ RedisScan func(src interface{}) error

type Script

+ func (s *Script) Hash() string

v1.1.0

May 11, 2017

Changes in this version

+ func Positions(result interface{}, err error) ([]*[2]float64, error)

type DialOption

+ func DialTLSConfig(c *tls.Config) DialOption

+ func DialTLSSkipVerify(skip bool) DialOption

v1.0.0

Apr 14, 2016

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 Float64(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 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 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 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 DialOption struct

+ func DialConnectTimeout(d time.Duration) DialOption

+ func DialDatabase(db 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 DialWriteTimeout(d time.Duration) DialOption

+ type Error string

+ func (err Error) Error() string

+ type Message struct

+ Channel string

+ Data []byte

+ type PMessage struct

+ Channel string

+ Data []byte

+ Pattern string

+ type Pong struct

+ Data string

+ type Pool struct

+ Dial func() (Conn, error)

+ IdleTimeout time.Duration

+ MaxActive int

+ 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

+ 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) Subscribe(channel ...interface{}) error

+ func (c PubSubConn) Unsubscribe(channel ...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) 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

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