cache

type CachedHashQuery[T any] struct {
	// contains filtered or unexported fields
}

type CachedHashQueryOption[T any] func(*CachedHashQuery[T])

type CachedQuery[T any] struct {
	// contains filtered or unexported fields
}

type CachedQueryOption[T any] func(*CachedQuery[T])

type HashMarshalFunc[T any] func(value T) map[string]interface{}

type HashUnmarshalFunc[T any] func(hashData map[string]string) (T, error)

type ICache interface {
	// Get 获取缓存值
	Get(ctx context.Context, key string) *redis.StringCmd
	// Set 设置缓存值
	Set(ctx context.Context, key string, value any, expiration time.Duration) *redis.StatusCmd
	// Del 删除缓存
	Del(ctx context.Context, keys ...string) *redis.IntCmd
	// Pipeline 创建管道
	Pipeline() redis.Pipeliner
	// HSet 设置 Hash 字段
	HSet(ctx context.Context, key string, values ...any) *redis.IntCmd
	// HGetAll 获取 Hash 所有字段
	HGetAll(ctx context.Context, key string) *redis.MapStringStringCmd
	// HDel 删除 Hash 字段
	HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd
	// Expire 设置过期时间
	Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
}

type KeyFunc func(params ...any) string

type QueryFunc[T any] func(ctx context.Context) (T, error)

type Redis struct {
	Mode             string
	Address          string
	Password         string
	DB               int
	PoolSize         int
	UseTLS           bool
	MasterName       string
	SentinelUsername string
	SentinelPassword string
	DialTimeout      time.Duration // 连接超时
	ReadTimeout      time.Duration // 读超时
	WriteTimeout     time.Duration // 写超时
	MaxRedirects     int           // 集群模式最大重定向次数
}

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