Struct CacheManager 

pub struct CacheManager { /* private fields */ }

缓存管理器

全局单例或通过依赖注入管理，负责：

• Redis 连接管理
• Key 索引维护
• 插件缓存清理

Implementations

impl CacheManager

pub async fn new( redis_url: &str, config: CacheConfig, ) -> Result<Self, CacheError>

创建新的 CacheManager

Arguments

• redis_url - Redis 连接 URL
• config - 缓存配置

Returns

• Result<Self, CacheError> - CacheManager 实例或错误

pub async fn new_with_defaults(redis_url: &str) -> Result<Self, CacheError>

使用默认配置创建 CacheManager

Arguments

• redis_url - Redis 连接 URL

Returns

• Result<Self, CacheError> - CacheManager 实例或错误

pub fn create_plugin_cache(&self, plugin_id: String) -> PluginCache

为插件创建 Cache 实例

Arguments

• plugin_id - 插件 ID

Returns

• PluginCache - 插件缓存实例

pub async fn clear_plugin(&self, plugin_id: &str) -> Result<u64, CacheError>

清理指定插件的所有缓存

Arguments

• plugin_id - 插件 ID

Returns

• Result<u64, CacheError> - 删除的 Key 数量

性能优化

• 优先使用索引获取 Key（快速）
• 仅在索引为空或需要完整性保证时使用 SCAN

pub async fn clear_plugin_for_upgrade( &self, plugin_id: &str, ) -> Result<u64, CacheError>

清理插件缓存（用于升级场景）

Arguments

• plugin_id - 插件 ID

Returns

• Result<u64, CacheError> - 删除的 Key 数量

pub async fn clear_plugin_for_disable( &self, plugin_id: &str, force: bool, ) -> Result<u64, CacheError>

清理插件缓存（用于禁用场景）

Arguments

• plugin_id - 插件 ID
• force - 是否强制清理

Returns

• Result<u64, CacheError> - 删除的 Key 数量

pub async fn clear_module( &self, plugin_id: &str, module: &str, ) -> Result<u64, CacheError>

清理指定插件的指定模块缓存

Arguments

• plugin_id - 插件 ID
• module - 模块标识（biz），如 user、order、config 等

Returns

• Result<u64, CacheError> - 删除的 Key 数量

Example

// 清空 user_plugin 插件的 user 模块缓存
cache_manager.clear_module("user_plugin", "user").await?;

// 清空 order_service 插件的 order 模块缓存
cache_manager.clear_module("order_service", "order").await?;

pub async fn health_check(&self) -> Result<(), CacheError>

Redis 连接健康检查

Returns

• Result<(), CacheError> - 健康检查结果

用途

用于定期检查 Redis 连接是否正常，可用于自动重连机制

Trait Implementations

impl Clone for CacheManager

fn clone(&self) -> CacheManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.