redis

package

Go to main page

Versions in this module

v1

v1.4.6

Mar 3, 2021

v1.4.5

Mar 2, 2021

v1.4.4

Feb 26, 2021

Changes in this version

type QueuePool

+ func (p *QueuePool) WaitingCount() int

v1.4.3

Aug 21, 2020

v1.4.2

Aug 20, 2020

Changes in this version

type QueuePool

+ func (p *QueuePool) GetRetry(timeout time.Duration, hint int, retry int) (Conn, error)

v1.4.1

Aug 19, 2020

v1.4.0

Jun 8, 2020

v1.3.3

May 21, 2020

Changes in this version

type QueuePool

+ func (p *QueuePool) GetUntil(timeout time.Duration, hint int) (Conn, error)

v1.3.2

Sep 18, 2018

v1.3.1

Sep 16, 2018

v1.3.0

Sep 5, 2018

Changes in this version

type QueuePool

+ func (p *QueuePool) SetMaxActive(c int32)

v1.2.0

Apr 4, 2018

Changes in this version

+ type Argument interface

+ RedisArg func() interface{}

type Conn

+ RemoteAddrStr func() string

type Pool

+ func (p *Pool) IdleCount() int

+ type QueuePool struct

+ Dial func() (Conn, error)

+ IdleTimeout time.Duration

+ MaxActive int

+ MaxIdle int

+ TestOnBorrow func(c Conn, t time.Time) error

+ func NewQueuePool(newFn func() (Conn, error), maxIdle int, maxActive int) *QueuePool

+ func (p *QueuePool) Close() error

+ func (p *QueuePool) Count() int

+ func (p *QueuePool) Get(timeout time.Duration) (Conn, error)

+ func (p *QueuePool) IsActive() bool

+ func (p *QueuePool) PutConnection(conn Conn)

+ func (p *QueuePool) Refresh()

+ 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