Struct LocalInvalidationBus 

pub struct LocalInvalidationBus { /* private fields */ }

进程内失效总线（单实例用）

基于 tokio::sync::broadcast 实现多订阅者广播。 subscribe() 返回的迭代器会 drain 当前已缓冲但未消费的消息。

Implementations

impl LocalInvalidationBus

pub fn new(capacity: usize) -> LocalInvalidationBus

创建进程内失效总线，capacity 为广播缓冲区容量

Trait Implementations

impl Default for LocalInvalidationBus

fn default() -> LocalInvalidationBus

Returns the “default value” for a type.

impl InvalidationBus for LocalInvalidationBus

fn publish(&self, message: InvalidationMessage)

发布失效消息

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

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