Struct RedisPubSubInvalidationBus 

pub struct RedisPubSubInvalidationBus { /* private fields */ }

Redis Pub/Sub 跨实例失效总线

复用既有 Redis 连接管理（自动重连），Pub/Sub 专用连接。 消息序列化为 ≤1KB JSON，跳过本实例 instance_id 避免自回环。

Implementations

impl RedisPubSubInvalidationBus

pub fn new(client: ConnectionManager, instance_id: impl Into<String>) -> Self

创建 Redis Pub/Sub 失效总线

pub fn disconnected(instance_id: impl Into<String>) -> Self

创建未连接的失效总线（降级为本地失效）

pub fn with_channel(self, channel: impl Into<String>) -> Self

设置通道名

pub fn instance_id(&self) -> &str

获取本实例 ID

pub fn push_received(&self, message: InvalidationMessage)

接收消息（从外部订阅循环调用，写入本地缓冲）

Trait Implementations

impl InvalidationBus for RedisPubSubInvalidationBus

fn publish(&self, message: InvalidationMessage)

发布失效消息

fn subscribe(&self) -> Box<dyn Iterator<Item = InvalidationMessage> + Send>

订阅失效消息（返回一个迭代器，drain 当前缓冲的消息）