redisCache

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

type DealWith interface {
	DealWithOnce(z redis.Z) error
	DealWithMultiple(z []redis.Z) error
}

type DelayedQueue interface {
	Put(ctx context.Context, key string, z []*redis.Z, ttl time.Duration) error
	DealWithOnce(ctx context.Context, key string, min, max float64, ttl time.Duration) error
	DealWithMultiple(ctx context.Context, key string, min, max float64, ttl time.Duration) error
}

type Item struct {
	Ctx context.Context

	Key   string
	Value interface{}

	// TTL is the cache expiration time.
	// Default TTL is 1 hour.
	TTL time.Duration

	// Do returns value to be cached.
	Do func(*Item) (interface{}, error)

	// SetXX only sets the key if it already exists.
	SetXX bool

	// SetNX only sets the key if it does not already exist.
	SetNX bool

	// SkipLocalCache skips local cache as if it is not set.
	SkipLocalCache bool
}

type LocalCache interface {
	Set(key string, data []byte)
	Get(key string) ([]byte, bool)
	Del(key string)
}

type LockType int

type MarshalFunc func(interface{}) ([]byte, error)

type Options struct {
	Redis        redis.Cmdable
	LocalCache   LocalCache
	StatsEnabled bool
	Marshal      MarshalFunc
	Unmarshal    UnmarshalFunc
}

type Pagination struct {
	Min       string
	Max       string
	Limit     int64 `json:"limit"`
	Offset    int64 `json:"offset"`
	TotalRows int64 `json:"total_rows"`
}

type RedisLock interface {
	// 加锁, 返回加锁是否成功
	TryLock(ctx context.Context, key string, val interface{}, ttl time.Duration) (bool, []byte, error)
	// 解锁
	UnLock(ctx context.Context, key string, val interface{}) error
	// 等待释放锁
	WaitUnLock(ctx context.Context, key string) (err error)
	// 续约
	RenewLock(ctx context.Context, key string, value interface{}, ttl time.Duration) (err error)
	// 加锁, 如果有锁，等待锁释放再添加锁
	WaitLock(ctx context.Context, key string, val interface{}, ttl time.Duration) (bool, error)
}

type SortSet interface {
	// 添加元素
	CacheIndexAdd(ctx context.Context, key string, value []*redis.Z) (result int64, err error)
	// 查询，通过分页
	CacheIndexGetByOrder(ctx context.Context, key string, page *Pagination) (result []string, err error)
	// 查询，通过分数分页
	CacheIndexGetByScore(ctx context.Context, key string, page *Pagination) (result []string, err error)
	// 获取有序集合数量
	CacheGetSortSetCount(ctx context.Context, key string) (result int64, err error)
	// 判断元素是否存在有序集合
	CacheExistsSortSet(ctx context.Context, key, value string) (result bool, err error)
	// 删除有序集合元素
	CacheDelMember(ctx context.Context, key, value string) (err error)
}

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

type UnmarshalFunc func([]byte, interface{}) error