cache

package

v0.4.1 Latest Latest Go to latest Published: Jul 5, 2026 License: MIT Imports: 9 Imported by: 1

Details

View Source

const (
	ActiveServer = RedisState(0)
	DownServer   = RedisState(1)
)

This section is empty.

This section is empty.

type Cache struct {
	*RedisManager
}

Cache

func NewCache(conf *config.Config) (*Cache, error)

NewCache 从配置初始化缓存配置了的 redis 连接失败会返回错误(fail-fast);完全没配置 redis 时返回可用的空实例

func (c *Cache) Close() error

Close 关闭所有缓存连接

type Redis struct {
	*redis.Client
	State   RedisState `json:"state"`
	Options *redis.Options
}

func NewRedis(client *redis.Client, options *redis.Options) *Redis

func (r *Redis) GetClient() *redis.Client

func (r Redis) IsEqual(options *redis.Options) bool

func (this *Redis) MarshalJSON() ([]byte, error)

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

func NewRedisManager(conf *config.Config) (*RedisManager, error)

NewRedisManager 从配置初始化所有 redis 连接配置了的 redis 必须连接成功(ping),否则返回错误(fail-fast); 完全没有 redis 配置时返回空 manager,不报错。

func (rm *RedisManager) Close() error

Close 关闭所有Redis连接

func (rm *RedisManager) Get(redisConfigCenterKey string) (*Redis, error)

func (rm *RedisManager) Names() []string

Names 返回所有已初始化的 redis 配置名

func (rm *RedisManager) PingAll(ctx context.Context) map[string]error

PingAll 对所有 redis 执行 Ping,返回每个实例的结果(nil 表示正常)

type RedisState int