zanredisdb

Mar 4, 2021

Changes in this version

type HostStats

+ PoolWaitCnt int

+ RangePoolWaitCnt int

type ZanRedisClient

+ func (self *ZanRedisClient) Stats() map[string]HostStats

Aug 20, 2020

Changes in this version

type Conf

+ MaxRetryGetConn int

Jun 8, 2020

Changes in this version

type Conf

+ MaxConnWait time.Duration

type RedisHost

+ func (rh *RedisHost) Conn(poolType PoolType, hint int) (redis.Conn, error)

Apr 18, 2020

Changes in this version

+ func IsTimeoutErr(err error) bool

type RedisHost

+ func (rh *RedisHost) IsActive() bool

Aug 7, 2019

Changes in this version

+ func IsConnectClosed(err error) bool

type Conf

+ func NewDefaultConf() *Conf

Jun 23, 2019

Changes in this version

+ var ErrInvalidKey = errors.New("invalid key format")

+ func ValidPrefix(k string) bool

type Cluster

+ func (cluster *Cluster) IsStopped() bool

type PKey

+ func ParsePKey(k string) (*PKey, error)

Sep 5, 2018

Changes in this version

+ const LOG_DEBUG

+ const LOG_ERR

+ const LOG_INFO

+ const MinRetrySleep

+ var ErrSizeExceedLimit = errors.New("key value size exceeded the limit")

+ var LargeKeyPoolNum = 3

+ func IsSlowCmd(cmd string) bool

type Cluster

+ func (cluster *Cluster) ChangeMaxActive(active int)

+ func (cluster *Cluster) GetConnForLarge(pk []byte, leader bool, tryLocalForRead bool, vsize int) (redis.Conn, error)

+ func (cluster *Cluster) GetHostAndConnForLarge(pk []byte, leader bool, tryLocalForRead bool, vsize int) (*RedisHost, redis.Conn, error)

+ func (cluster *Cluster) GetHostStats() map[string]HostStats

+ func (cluster *Cluster) IsSameDCFirst() bool

type Conf

+ MultiConf MultiClusterConf

+ func (conf *Conf) CheckValid() error

+ type HostStats struct

+ FailedCnt int64

+ FailedTs int64

+ LargeKeyPoolCnt []int

+ PoolCnt int

+ RangePoolCnt int

+ type LargeKeyConf struct

+ GetConnTimeoutForLargeKey time.Duration

+ MaxAllowedValueSize int

+ MinPoolSize int

+ func NewLargeKeyConf() *LargeKeyConf

+ type MultiClusterConf []RemoteClusterConf

+ func (mcc MultiClusterConf) CheckValid() error

+ type PoolType int

+ const DefPool

+ const LargeKeyPool

+ const RangePool

type RedisHost

+ func (rh *RedisHost) ChangeMaxActive(maxActive int, rangeRatio float64)

+ func (rh *RedisHost) Stats() HostStats

+ type RemoteClusterConf struct

+ ClusterDC string

+ IsPrimary bool

+ LookupList []string

type ZanRedisClient

+ func (self *ZanRedisClient) DoRedisForException(cmd string, shardingKey []byte, toLeader bool, args ...interface{}) (interface{}, error)

+ func (self *ZanRedisClient) DoRedisForRead(cmd string, shardingKey []byte, toLeader bool, args ...interface{}) (interface{}, error)

+ func (self *ZanRedisClient) DoRedisForWrite(cmd string, shardingKey []byte, toLeader bool, args ...interface{}) (interface{}, error)

+ func (self *ZanRedisClient) DoRedisTryLocalRead(cmd string, shardingKey []byte, toLeader bool, args ...interface{}) (interface{}, error)

+ func (self *ZanRedisClient) SetLargeKeyConf(conf *LargeKeyConf)

Jun 4, 2018

Changes in this version

+ const DefaultConnPoolMaxActive

+ const DefaultConnPoolMaxIdle

+ const MIN_RETRY_SLEEP

+ var ErrCntForStopRW = 3

+ var FailedOnClusterChanged = "ERR_CLUSTER_CHANGED"

+ var FailedOnNodeStopped = "the node stopped"

+ var FailedOnNotLeader = "E_FAILED_ON_NOT_LEADER"

+ var FailedOnNotWritable = "E_FAILED_ON_NOT_WRITABLE"

+ var MaxRetryInterval = time.Minute

+ var NextRetryFailedInterval = time.Minute * 2

+ var RetryFailedInterval = time.Second * 5

+ func DoRedisCmd(conn redis.Conn, cmdName string, args ...interface{}) (reply interface{}, err error)

+ func FindString(src []string, f string) int

+ func GetHashedPartitionID(pk []byte, pnum int) int

+ func IsConnectRefused(err error) bool

+ func IsFailedOnClusterChanged(err error) bool

+ func IsFailedOnNotWritable(err error) bool

+ func IsRangeCmd(cmd string) bool

+ func SetLogger(level int32, l Logger)

+ type Cluster struct

+ LookupList []string

+ func NewCluster(conf *Conf) *Cluster

+ func (cluster *Cluster) Close()

+ func (cluster *Cluster) GetAllHostsByPart(pid int) ([]*RedisHost, error)

+ func (cluster *Cluster) GetConn(pk []byte, leader bool, isRangeQuery bool) (redis.Conn, error)

+ func (cluster *Cluster) GetConnsByHosts(hosts []string, isRangeQuery bool) ([]redis.Conn, error)

+ func (cluster *Cluster) GetConnsForAllParts(isRangeQuery bool) ([]redis.Conn, error)

+ func (cluster *Cluster) GetHostAndConn(pk []byte, leader bool, isRangeQuery bool) (*RedisHost, redis.Conn, error)

+ func (cluster *Cluster) GetHostByPart(pid int, leader bool) (*RedisHost, error)

+ func (cluster *Cluster) GetNodeHost(pk []byte, leader bool) (*RedisHost, error)

+ func (cluster *Cluster) GetPartitionNum() int

+ func (cluster *Cluster) MaybeTriggerCheckForError(err error, delay time.Duration) bool

+ type Conf struct

+ DC string

+ DialTimeout time.Duration

+ IdleTimeout time.Duration

+ LookupList []string

+ MaxActiveConn int

+ MaxIdleConn int

+ Namespace string

+ Password string

+ RangeConnRatio float64

+ RangeReadTimeout time.Duration

+ ReadTimeout time.Duration

+ TendInterval int64

+ WriteTimeout time.Duration

+ type HashElem struct

+ Field []byte

+ Value []byte

+ type LevelLogger struct

+ Logger Logger

+ func NewLevelLogger(l int32, logger Logger) *LevelLogger

+ func (self *LevelLogger) Debugf(f string, args ...interface{})

+ func (self *LevelLogger) Detailf(f string, args ...interface{})

+ func (self *LevelLogger) Errorf(f string, args ...interface{})

+ func (self *LevelLogger) Errorln(f string)

+ func (self *LevelLogger) Flush()

+ func (self *LevelLogger) Infof(f string, args ...interface{})

+ func (self *LevelLogger) Infoln(f string)

+ func (self *LevelLogger) Level() int32

+ func (self *LevelLogger) Printf(f string, args ...interface{})

+ func (self *LevelLogger) SetLevel(l int32)

+ func (self *LevelLogger) Warningf(f string, args ...interface{})

+ func (self *LevelLogger) Warningln(f string)

+ type Logger interface

+ Flush func()

+ Output func(depth int, s string)

+ OutputErr func(depth int, s string)

+ type NodeInfo struct

+ DataRoot string

+ Epoch int64

+ Hostname string

+ HttpPort string

+ ID string

+ NodeIP string

+ RaftTransportAddr string

+ RedisPort string

+ RegID uint64

+ RpcPort string

+ RsyncModule string

+ Tags map[string]bool

+ Version string

+ type PKey struct

+ Namespace string

+ PK []byte

+ RawKey []byte

+ Set string

+ func NewPKey(ns string, set string, pk []byte) *PKey

+ func (self *PKey) ShardingKey() []byte

+ func (self *PKey) String() string

+ type PartitionAddrInfo struct

+ Leader string

+ ReplicaInfos []node

+ Replicas []string

+ ReplicasDCInfo []string

+ type PartitionAddrs struct

+ PList []PartitionAddrInfo

+ PNum int

+ type PartitionInfo struct

+ Leader *RedisHost

+ Replicas []*RedisHost

+ type PartitionNodeInfo struct

+ Leader node

+ Replicas []node

+ type Partitions struct

+ Epoch int64

+ PList []PartitionInfo

+ PNum int

+ type PipelineCmd struct

+ Args []interface{}

+ CmdName string

+ ShardingKey []byte

+ ToLeader bool

+ type PipelineCmdList []PipelineCmd

+ func (pl *PipelineCmdList) Add(cmd string, shardingKey []byte, toLeader bool, args ...interface{})

+ type RedisHost struct

+ func (rh *RedisHost) Addr() string

+ func (rh *RedisHost) CloseConn()

+ func (rh *RedisHost) ConnPool(isRangeQuery bool) *redis.QueuePool

+ func (rh *RedisHost) GrpcAddr() string

+ func (rh *RedisHost) IncSuccess()

+ func (rh *RedisHost) InitConnPool(newFn func() (redis.Conn, error), newRangeFn func() (redis.Conn, error), ...)

+ func (rh *RedisHost) MaybeIncFailed(err error)

+ func (rh *RedisHost) Refresh()

+ type ScanKey struct

+ Count int

+ Cursor []byte

+ Namespace string

+ RawKey []byte

+ Set string

+ Type string

+ func NewScanKey(ns, set, t string, count int, cursor []byte) *ScanKey

+ func (self *ScanKey) String() string

+ type SimpleLogger struct

+ func NewSimpleLogger() *SimpleLogger

+ func (self *SimpleLogger) Flush()

+ func (self *SimpleLogger) Output(depth int, s string)

+ func (self *SimpleLogger) OutputErr(depth int, s string)

+ type ZSetElem struct

+ Member []byte

+ Score float64

+ type ZanRedisClient struct

+ func NewZanRedisClient(conf *Conf) *ZanRedisClient

+ func (client *ZanRedisClient) AdvScan(tp, set string, count int, cursor []byte) ([]byte, [][]byte, error)

+ func (client *ZanRedisClient) AdvScanChannel(tp, set string, stopC chan struct{}) chan []byte

+ func (client *ZanRedisClient) DoFullScan(cmd, tp, set string, count int, cursor []byte) ([]byte, []interface{}, error)

+ func (client *ZanRedisClient) DoFullScanChannel(tp, set string, stopC chan struct{}) chan interface{}

+ func (client *ZanRedisClient) DoScan(cmd, tp, set string, count int, cursor []byte) ([]byte, [][]byte, error)

+ func (client *ZanRedisClient) DoScanChannel(cmd, tp, set string, stopC chan struct{}) chan []byte

+ func (client *ZanRedisClient) FullScan(tp, set string, count int, cursor []byte) ([]byte, []interface{}, error)

+ func (client *ZanRedisClient) FullScanChannel(tp, set string, stopC chan struct{}) chan interface{}

+ func (client *ZanRedisClient) HScan(set string, key []byte, count int, cursor []byte) ([]byte, []HashElem, error)

+ func (client *ZanRedisClient) HScanChannel(set string, key []byte, stopC chan struct{}) chan []byte

+ func (client *ZanRedisClient) KVScan(set string, count int, cursor []byte) ([]byte, [][]byte, error)

+ func (client *ZanRedisClient) KVScanChannel(set string, stopC chan struct{}) chan []byte

+ func (client *ZanRedisClient) SScan(set string, key []byte, count int, cursor []byte) ([]byte, [][]byte, error)

+ func (client *ZanRedisClient) SScanChannel(set string, key []byte, stopC chan struct{}) chan []byte

+ func (client *ZanRedisClient) ZScan(set string, key []byte, count int, cursor []byte) ([]byte, []ZSetElem, error)

+ func (client *ZanRedisClient) ZScanChannel(set string, key []byte, stopC chan struct{}) chan ZSetElem

+ func (self *ZanRedisClient) DoRedis(cmd string, shardingKey []byte, toLeader bool, args ...interface{}) (interface{}, error)

+ func (self *ZanRedisClient) FlushAndWaitPipelineCmd(cmds PipelineCmdList) ([]interface{}, []error)

+ func (self *ZanRedisClient) KVDel(set string, key []byte) (int, error)

+ func (self *ZanRedisClient) KVGet(set string, key []byte) ([]byte, error)

+ func (self *ZanRedisClient) KVMDel(readLeader bool, pKeys ...*PKey) (int64, error)

+ func (self *ZanRedisClient) KVMExists(readLeader bool, pKeys ...*PKey) (int64, error)

+ func (self *ZanRedisClient) KVMGet(readLeader bool, pKeys ...*PKey) ([][]byte, error)

+ func (self *ZanRedisClient) KVSet(set string, key []byte, value []byte) error

+ func (self *ZanRedisClient) KVSetNX(set string, key []byte, value []byte) (int, error)

+ func (self *ZanRedisClient) Start()

+ func (self *ZanRedisClient) Stop()

+ func (self *ZanRedisClient) SwitchSameDC(useSameDC bool)