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