richTypes

type KeysQuerySeter interface {
	// 查找所有符合给定模式pattern（正则表达式）的 key 。
	Keys() ([]string, error)
	Del() error
}

type ListQuerySeter interface {
	QuerySeter
	// ========= 连贯操作接口 =========
	// 保护数据库
	Protect(time.Duration) ListQuerySeter
	// 重构List的方法（基于RPush）
	SetRebuildFunc(f func(ctx context.Context) ([]interface{}, time.Duration, error)) ListQuerySeter
	// 传入Ctx
	WithContext(ctx context.Context) ListQuerySeter
	// ========= 常规操作 ===========
	ScanSlice(slc interface{}, start, stop int64) error
}

type Querier interface {
	redis.UniversalClient
}

type QuerySeter interface {
	// 获取当前查询的key
	Key() string
	// 重构缓存的接口
	Rebuilding() error
}

type Richer interface {
	// 构造String查询构造器
	QueryString(i interface{}) StringQuerySeter
	// 构造ZSet查询构造器
	QueryZSet(i interface{}) ZSetQuerySeter
	// 构造List查询构造器
	QueryList(i interface{}) ListQuerySeter

	// 设置使用的Redis链接
	Using(alias string) error
	// 当前生效的查询器
	Querier() Querier
}

type SetQuerier interface {
	Querier
	SAddExpire(key string, members []interface{}, expire time.Duration) (int64, error)
	SAddExpireIfExist(key string, members []interface{}, expire time.Duration) (int64, error)
	SCardIfExist(key string) (int64, error)
	SMembersIfExist(key string) ([]string, error)
	SIsMemberIfExist(key string, member interface{}) (bool, error)
}

type SetQuerySeter interface {
	QuerySeter

	// ========= 连贯操作接口 =========
	// 保护数据库
	Protect(expire time.Duration) SetQuerySeter
	// 重构ZSet的方法
	SetRebuildFunc(rebuildFunc func() ([]interface{}, time.Duration)) SetQuerySeter

	// ========== 读取接口 ==========
	// 获取成员数量
	Count() (int64, error)
	// 获取所有成员
	Members() ([]string, error)
	// 判断目标成员是否是榜单的成员（按value判断）
	IsMember(member interface{}) (bool, error)

	// ========== 写入接口 ==========
	// 向集合中增加一个成员，并设置其过期时间
	AddExpire(member interface{}, expire time.Duration) (int64, error)
	// 从集合中移除n个成员
	Rem(member ...interface{}) error
}

type StringQuerySeter interface {
	QuerySeter
	// ========= 连贯操作接口 =========
	// 保护数据库
	Protect(time.Duration) StringQuerySeter
	// 重构String的方法
	SetRebuildFunc(func(ctx context.Context) (interface{}, time.Duration)) StringQuerySeter
	// 传入Ctx
	WithContext(ctx context.Context) StringQuerySeter

	// ======== 读取接口 ========
	// 获取键值
	Get() (string, error)
	// 将值写入传入实例
	Scan(interface{}) error

	// ========= 写入接口 =========
	// 设置值（如果为实例，则调用encoding/binary接口）
	Set(interface{}, time.Duration) error
	// 尝试写入当前Key，如果key存在则不写入
	SetNX(interface{}, time.Duration) (bool, error)
	// 移除当前key
	Del() error
	// 增加指定的数值
	IncrBy(int64) (int64, error)
}

type ZSetQuerier interface {
	Querier

	ZAddExpire(key string, members []redis.Z, expire time.Duration) (int64, error)
	ZAddExpireIfExist(key string, members []redis.Z, expire time.Duration) (int64, error)

	ZIsMemberIfExist(key string, member string) (bool, error)
	ZCardIfExist(key string) (int64, error)
	ZScoreIfExist(key string, member string) (float64, error)

	ZRangeIfExist(key string, start, stop int64) ([]string, error)
	ZRevRangeIfExist(key string, start, stop int64) ([]string, error)

	ZRangeWithScoresIfExist(key string, start int64, stop int64) ([]redis.Z, error)
	ZRevRangeWithScoresIfExist(key string, start, stop int64) ([]redis.Z, error)

	ZRangeByScoreIfExist(key string, opt redis.ZRangeBy) ([]string, error)
	ZRevRangeByScoreIfExist(key string, opt redis.ZRangeBy) ([]string, error)
}

type ZSetQuerySeter interface {
	QuerySeter
	// ========= 连贯操作接口 =========
	// 保护数据库
	Protect(expire time.Duration) ZSetQuerySeter
	// 重构ZSet的方法
	SetRebuildFunc(rebuildFunc func(ctx context.Context) ([]redis.Z, time.Duration)) ZSetQuerySeter
	// 传入Ctx
	WithContext(ctx context.Context) ZSetQuerySeter

	// ========= 查询接口 =========
	// 判断目标成员是否是榜单的成员（按value判断）
	IsMember(member string) (bool, error)
	// 获取成员数量
	Count() (int64, error)
	// 获取所有成员
	Members() ([]string, error)
	// 获取指定成员的分数
	Score(member string) (float64, error)
	// 按分数升序获取排名第start到stop的所有成员
	RangeASC(start, stop int64) ([]string, error)
	// 按分数降序获取排名第start到stop的所有成员
	RangeDESC(start, stop int64) ([]string, error)
	// 按分数降序获取排名第start到stop的所有成员及成员分数
	RangeASCWithScores(start, stop int64) ([]redis.Z, error)
	// 按分数降序获取排名第start到stop的所有成员及成员分数
	RangeDESCWithScores(start, stop int64) ([]redis.Z, error)
	// 按分数升序获取指定分数区间内的成员
	// max,min除了数字外，可取"+inf"或"-inf"表示无限大或无限小
	// 默认情况下，区间的取值使用闭区间(小于等于或大于等于)，你也可以通过给参数前增加'('符号来使用可选的开区间(小于或大于)。
	// 例如：ZRANGEBYSCORE zset (1 5
	// 表示：所有符合条件 1<score<=5 的成员
	RangeByScoreASC(min, max string, offset, count int64) ([]string, error)
	// 按分数降序获取指定分数区间内的成员
	// max,min除了数字外，可取"+inf"或"-inf"表示无限大或无限小（rorm.InfinityPositive\rorm.InfinityNegative）
	// 默认情况下，区间的取值使用闭区间(小于等于或大于等于)，你也可以通过给参数前增加'('符号来使用可选的开区间(小于或大于)。
	// 例如：ZREVRANGEBYSCORE zset 5 (1
	// 表示：所有符合条件 5>score>=1的成员
	RangeByScoreDESC(min, max string, offset, count int64) ([]string, error)

	// ========= 写入接口 =========
	// 向已存在的集合中增加一个成员，并设置其过期时间
	AddExpire(member interface{}, score float64, expire time.Duration) (int64, error)
	// 从已存在的集合中移除n个成员
	Rem(member ...interface{}) error
}