Struct GossipInvalidationBus 

pub struct GossipInvalidationBus { /* private fields */ }

Gossip 去中心化失效总线

点对点发送到所有已知节点，HMAC 共享密钥认证， seen_messages 去重避免重复传播。

Implementations

impl GossipInvalidationBus

pub fn new( nodes: Vec<NodeAddr>, shared_secret: Vec<u8>, instance_id: impl Into<String>, ) -> Self

创建 Gossip 失效总线

pub fn instance_id(&self) -> &str

获取本实例 ID

pub fn receive( &self, message: InvalidationMessage, msg_id: u64, hmac_tag: &[u8], ) -> bool

接收消息（从其他节点调用，需认证 + 去重）

Trait Implementations

impl InvalidationBus for GossipInvalidationBus

fn publish(&self, message: InvalidationMessage)

发布失效消息

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

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