redis

package

Go to main page

Versions in this module

v1

v1.9.2

Feb 25, 2024

v1.9.1

Feb 20, 2024

v1.9.0

Feb 20, 2024

v1.8.10

Feb 20, 2024

retracted

Changes in this version

type Pool

+ TestOnBorrowContext func(ctx context.Context, c Conn, lastUsed time.Time) error

v1.8.9

Jul 6, 2022

Changes in this version

+ func Float64Map(result interface{}, err error) (map[string]float64, error)

+ type Latency struct

+ Latest time.Duration

+ Max time.Duration

+ Name string

+ Time time.Time

+ func Latencies(result interface{}, err error) ([]Latency, error)

+ type LatencyHistory struct

+ ExecutionTime time.Duration

+ Time time.Time

+ func LatencyHistories(result interface{}, err error) ([]LatencyHistory, error)

type PubSubConn

+ func (c PubSubConn) ReceiveContext(ctx context.Context) interface{}

v1.8.8

Jan 4, 2022

v1.8.7

Jan 4, 2022

v1.8.6

Oct 15, 2021

Changes in this version

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

+ func ReceiveContext(c Conn, ctx context.Context) (interface{}, error)

type Conn

+ func DialURLContext(ctx context.Context, rawurl string, options ...DialOption) (Conn, error)

+ type ConnWithContext interface

+ DoContext func(ctx context.Context, commandName string, args ...interface{}) (reply interface{}, err error)

+ ReceiveContext func(ctx context.Context) (reply interface{}, err error)

type Script

+ func (s *Script) DoContext(ctx context.Context, c Conn, keysAndArgs ...interface{}) (interface{}, error)

v1.8.5

Jun 10, 2021

v1.8.4

Feb 18, 2021

v1.8.3

Nov 19, 2020

Changes in this version

type DialOption

+ func DialTLSHandshakeTimeout(d time.Duration) DialOption

v1.8.2

Jun 8, 2020

Changes in this version

type Conn

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

type DialOption

+ func DialContextFunc(f func(ctx context.Context, network, addr string) (net.Conn, error)) DialOption

+ func DialUsername(username string) DialOption

v1.8.1

May 6, 2020

v1.8.0

Apr 30, 2020

v1.7.2

Apr 30, 2020

Changes in this version

+ func Uint64Map(result interface{}, err error) (map[string]uint64, error)

+ func Uint64s(reply interface{}, err error) ([]uint64, error)

type DialOption

+ func DialClientName(name string) DialOption

type Pool

+ DialContext func(ctx context.Context) (Conn, error)

type PoolStats

+ WaitCount int64

+ WaitDuration time.Duration

+ type SlowLog struct

+ Args []string

+ ClientAddr string

+ ClientName string

+ ExecutionTime time.Duration

+ ID int64

+ Time time.Time

+ func SlowLogs(result interface{}, err error) ([]SlowLog, error)

v1.7.0

Dec 13, 2018

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

+ func NewLoggingConnFilter(conn Conn, logger *log.Logger, prefix string, skip func(cmdName string) bool) 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

Incompatible versions in this module

v2.0.0+incompatible

Mar 14, 2018

retracted

Other modules containing this package

github.com/gomodule/redigo/redis

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