Struct GossipSubManager 

pub struct GossipSubManager { /* private fields */ }

GossipSub manager

Implementations

impl GossipSubManager

pub fn new(config: GossipSubConfig) -> Self

Create a new GossipSub manager

pub fn subscribe(&self, topic: TopicId) -> Result<(), GossipSubError>

Subscribe to a topic

pub fn unsubscribe(&self, topic: &TopicId) -> Result<(), GossipSubError>

Unsubscribe from a topic

pub fn publish( &self, topic: TopicId, data: Vec<u8>, source: PeerId, ) -> Result<MessageId, GossipSubError>

Publish a message to a topic

pub fn handle_message( &self, message: GossipSubMessage, ) -> Result<bool, GossipSubError>

Handle received message

pub fn add_peer_to_mesh( &self, topic: &TopicId, peer: PeerId, ) -> Result<(), GossipSubError>

Add peer to topic mesh

pub fn remove_peer_from_mesh( &self, topic: &TopicId, peer: &PeerId, ) -> Result<(), GossipSubError>

Remove peer from topic mesh

pub fn get_mesh_peers( &self, topic: &TopicId, ) -> Result<Vec<PeerId>, GossipSubError>

Get peers in topic mesh

pub fn get_peer_score(&self, peer: &PeerId) -> Option<PeerScore>

Get peer score

pub fn update_peer_score(&self, peer: &PeerId, topic: TopicId, score: f64)

Update peer score for a topic

pub fn get_peers_to_prune(&self, topic: &TopicId, threshold: f64) -> Vec<PeerId>

Get low-scoring peers that should be pruned

pub fn stats(&self) -> GossipSubStats

Get statistics

pub fn list_topics(&self) -> Vec<TopicId>

List subscribed topics

pub fn is_subscribed(&self, topic: &TopicId) -> bool

Check if subscribed to a topic

impl GossipSubManager

pub fn subscribe_inference_topics(&self) -> Result<(), GossipSubError>

Subscribe to all standard IPFRS inference topics

pub fn publish_inference_request( &self, request_bytes: &[u8], sender_peer_id: &str, ) -> Result<(), GossipSubError>

Publish an inference request to all subscribers

pub fn publish_inference_result( &self, result_bytes: &[u8], sender_peer_id: &str, ) -> Result<(), GossipSubError>

Publish an inference result to subscribers

pub fn announce_block( &self, cid: &str, sender_peer_id: &str, ) -> Result<(), GossipSubError>

Publish a block availability announcement

pub fn publish_gradient_cid( &self, cid: &str, sender_peer_id: &str, ) -> Result<(), GossipSubError>

Publish a gradient CID to the GRADIENT_SYNC topic so that peers can fetch it.

The cid is the content-address of the Arrow IPC block holding the gradient tensor. sender_peer_id is the local node’s peer-id string used as the message source.

pub fn announce_provider( &self, cid: &str, peer_id: &str, ) -> Result<(), GossipSubError>

Publish a provider record announcement

impl GossipSubManager

pub fn mesh_health(&self, topic: &TopicId) -> MeshHealthStatus

Return the aggregate mesh health status for a given topic.

Uses the manager’s configured mesh_n_low and mesh_n_high thresholds.

pub fn heal_mesh_if_needed(&self, topic: &TopicId) -> Vec<PeerId>

Attempt to heal the mesh for topic if it is underpeered.

Selects peers from the gossip peer score table that are not already in the mesh and grafts them in until D_low is satisfied. Returns the list of peer IDs grafted.

pub fn prune_mesh_if_needed(&self, topic: &TopicId) -> Vec<PeerId>

Prune the mesh for topic if it exceeds D_high.

Removes the lowest-scoring peers until the mesh size equals D_high. Returns the list of peer IDs pruned.