redisc

Apr 29, 2022

Changes in this version

+ const HashSlots

+ type BgErrorSrc uint

+ const ClusterRefresh

+ const RetryCloseConn

type Cluster

+ BgError func(BgErrorSrc, error)

+ LayoutRefresh func(old, new [HashSlots][]string)

+ func (c *Cluster) EachNode(replicas bool, fn func(addr string, conn redis.Conn) error) error

Feb 1, 2019

Changes in this version

type Cluster

+ PoolWaitTime time.Duration

Jan 27, 2019

Changes in this version

type Conn

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

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

Oct 8, 2017

Changes in this version

+ func BindConn(c redis.Conn, keys ...string) error

+ func IsCrossSlot(err error) bool

+ func IsTryAgain(err error) bool

+ func ReadOnlyConn(c redis.Conn) error

+ func RetryConn(c redis.Conn, maxAtt int, tryAgainDelay time.Duration) (redis.Conn, error)

+ func Slot(key string) int

+ func SplitBySlot(keys ...string) [][]string

+ type Cluster struct

+ CreatePool func(address string, options ...redis.DialOption) (*redis.Pool, error)

+ DialOptions []redis.DialOption

+ StartupNodes []string

+ func (c *Cluster) Close() error

+ func (c *Cluster) Dial() (redis.Conn, error)

+ func (c *Cluster) Get() redis.Conn

+ func (c *Cluster) Refresh() error

+ func (c *Cluster) Stats() map[string]redis.PoolStats

+ type Conn struct

+ func (c *Conn) Bind(keys ...string) error

+ func (c *Conn) Close() error

+ func (c *Conn) Do(cmd string, args ...interface{}) (interface{}, error)

+ func (c *Conn) Err() error

+ func (c *Conn) Flush() error

+ func (c *Conn) ReadOnly() error

+ func (c *Conn) Receive() (interface{}, error)

+ func (c *Conn) Send(cmd string, args ...interface{}) error

+ type RedirError struct

+ Addr string

+ NewSlot int

+ Type string

+ func ParseRedir(err error) *RedirError

+ func (e *RedirError) Error() string