redisx

type Config struct {
	Mode              RedisMode `default:"NormalDsn"` // 模式,支持NormalDsn、NormalAddr、Sentinel
	IsNeedFillDefault bool      // 是否需要填充默认参数

	// dial
	Dsn            string        // 用于NormalDsn模式
	Addr           string        // redis地址，用于NormalAddr模式
	Password       string        // redis密码
	Db             int           // db库
	ConnectTimeout time.Duration `default:"3s"`
	ReadTimeout    time.Duration `default:"3s"`
	WriteTimeout   time.Duration `default:"3s"`

	// pool
	MaxIdle     int           `default:"3"`
	MaxActive   int           `default:"64"`
	IdleTimeout time.Duration `default:"240s"`

	// sentinel
	Sentinel *Sentinel // 用于Sentinel
}

type Pool struct {
	// contains filtered or unexported fields
}

type RedisClient interface {
	Close() error
	Ping() error
	Get(key string) (interface{}, error)
	MGet(keys []string) (interface{}, error)
	Set(key string, value interface{}) error
	SetEx(key string, ttl int32, value interface{}) error
	MSet(vals map[string]interface{}) error
	Del(key string) error
	MDel(keys []string) error
	INCR(key string, addValue int64) (int64, error)
	Expire(key string, ttl int32) error
	ExpireAt(key string, expireTime time.Time) error
	HSet(key string, field string, value interface{}) error
	HMSet(key string, fields map[string]interface{}) error
	HDel(key string, field string) error
	HMDel(key string, fields []string) (interface{}, error)
	HGet(key string, field string) (interface{}, error)
	HMGet(key string, fields []string) (interface{}, error)
	HGetall(key string) (interface{}, error)
	Hkeys(key string) (interface{}, error)
	HIncr(key string, field string, addValue int64) (int64, error)
	Keys(pattern string) (interface{}, error)
	Scan(pattern string, count int64) ([]interface{}, error)
	DoScript(keyCount int, src string, keysAndArgs ...interface{}) (interface{}, error)
	NewMutex(name string, options ...redsync.Option) *redsync.Mutex
	UnlockMutex(mutex *redsync.Mutex) error
	Rename(oldKey string, newKey string) error
	RenameEx(oldKey string, newKey string) error
	Lpush(key string, val interface{}) error
	Rpop(key string) (interface{}, error)
	Llen(key string) (int64, error)
}

type RedisMode = string

type Sentinel struct {
	Addrs          []string
	MasterName     string
	Password       string        // sentinel密码
	ConnectTimeout time.Duration `default:"3s"`
	ReadTimeout    time.Duration `default:"3s"`
	WriteTimeout   time.Duration `default:"3s"`
}