Documentation ¶
Index ¶
- Constants
- func GetRediClient(config map[string]string) (redis.Cmdable, error)
- type IRedisRepository
- type RedisContent
- type RedisLimit
- type RedisLock
- type ReidsRepository
- func (r *ReidsRepository) CreateKey(prefix, key string) string
- func (r *ReidsRepository) Do(h func(redis.Cmdable))
- func (r *ReidsRepository) Get(key string, result interface{}) error
- func (r *ReidsRepository) GetIncr(key string, res map[string]int64) (err error)
- func (r *ReidsRepository) GetMany(keys []string, result interface{}) error
- func (r *ReidsRepository) Incr(key, field string, num int64) (int64, error)
- func (r *ReidsRepository) Remove(keys ...string) (int64, error)
- func (r *ReidsRepository) RemoveIncr(key string) error
- func (r *ReidsRepository) Set(key string, entity interface{}, ttl int64) (int64, error)
- func (r *ReidsRepository) SetMany(entityMap map[string]interface{}) (int64, error)
Constants ¶
View Source
const (
LuaString = `` /* 430-byte string literal not displayed */
)
Variables ¶
This section is empty.
Functions ¶
func GetRediClient ¶
GetRediClient 获取客户端
Types ¶
type IRedisRepository ¶
type IRedisRepository interface { //Set 插入单个 // entity 结构体 // ttl 单位秒 ,0为永不到期 Set(key string, entity interface{}, ttl int64) (int64, error) //SetMany 插入多个【单次20000个以下】 // entityMap 结构体字典 SetMany(entityMap map[string]interface{}) (int64, error) //Incr 递增字段值 //key hashid //fieid 字段名称 Incr(key, field string, num int64) (int64, error) //GetIncr 获取递增字段值 //key hashid //res 要获取的字段值 GetIncr(key string, res map[string]int64) (err error) //RemoveIncr 移除递增 //key hashid RemoveIncr(key string) error //Remove 删除单个 // key key值 Remove(key ...string) (int64, error) //Get 查询单个 // key key值 // result 查询的结果 Get(key string, result interface{}) error //GetMany 查询多个[只支持string类型] // keys key值切片 // result 查询的结果切片 GetMany(keys []string, result interface{}) error // CreateKey 创建内部key(配合直接使用数据库连接(GetClient)使用,其它方法不需要使用内部已调用) // prefix 前缀 // key CreateKey(prefix, key string) string //Do 直接执行 Do(f func(redis.Cmdable)) }
IRedisRepository 仓储接口(只支持string类型)
type RedisContent ¶
type RedisContent struct {
// contains filtered or unexported fields
}
RedisContent 集合上下文
func DataBaseMapping ¶
func DataBaseMapping(mappingName string, configFn func(mappingName string) map[string]string, prefixNamesFn func() map[string]int) (*RedisContent, error)
DataBaseMapping 添加映射 @client 连接对象
func (*RedisContent) GetRedisLimit ¶ added in v1.6.16
func (r *RedisContent) GetRedisLimit() *RedisLimit
GetRedisLimit 获取限速器
func (*RedisContent) GetRedisLock ¶ added in v1.6.16
func (r *RedisContent) GetRedisLock(lockKey string) *RedisLock
GetRedisLock 获取分布式锁
func (*RedisContent) GetRedisRepository ¶
func (r *RedisContent) GetRedisRepository(prefixName string) (IRedisRepository, bool)
GetRedisRepository 获取集合仓储 entity 结构体
type RedisLimit ¶ added in v1.6.16
type RedisLimit struct {
// contains filtered or unexported fields
}
RedisLimit redis限速器
func NewRedisLimit ¶ added in v1.6.16
func NewRedisLimit(store redis.Cmdable) *RedisLimit
NewRedisLimit 实例化限速器
type RedisLock ¶ added in v1.6.16
type RedisLock struct {
// contains filtered or unexported fields
}
A RedisLock is a redis lock.
func NewRedisLock ¶ added in v1.6.16
NewRedisLock returns a RedisLock.
type ReidsRepository ¶
type ReidsRepository struct {
// contains filtered or unexported fields
}
ReidsRepository 仓储(string)
func (*ReidsRepository) CreateKey ¶ added in v1.5.1
func (r *ReidsRepository) CreateKey(prefix, key string) string
CreateKey 创建内部key
func (*ReidsRepository) Do ¶ added in v1.6.13
func (r *ReidsRepository) Do(h func(redis.Cmdable))
Do 直接执行
func (*ReidsRepository) Get ¶
func (r *ReidsRepository) Get(key string, result interface{}) error
Get 查询单个 key key值 result 查询的结果
func (*ReidsRepository) GetIncr ¶ added in v1.5.1
func (r *ReidsRepository) GetIncr(key string, res map[string]int64) (err error)
GetIncr 获取递增值
func (*ReidsRepository) GetMany ¶
func (r *ReidsRepository) GetMany(keys []string, result interface{}) error
GetMany 查询多个 keys key值切片 result 查询的结果切片
func (*ReidsRepository) Incr ¶ added in v1.5.1
func (r *ReidsRepository) Incr(key, field string, num int64) (int64, error)
Incr 递增
func (*ReidsRepository) Remove ¶
func (r *ReidsRepository) Remove(keys ...string) (int64, error)
Remove 移除 keys key值切片
func (*ReidsRepository) RemoveIncr ¶ added in v1.5.1
func (r *ReidsRepository) RemoveIncr(key string) error
RemoveIncr 清理递增字段
Click to show internal directories.
Click to hide internal directories.