Struct libp2p::gossipsub::Gossipsub

pub struct Gossipsub { /* fields omitted */ }

Network behaviour that handles the gossipsub protocol.

Methods

impl Gossipsub

pub fn new(local_peer_id: PeerId, gs_config: GossipsubConfig) -> Gossipsub

Creates a Gossipsub struct given a set of parameters specified by gs_config.

pub fn subscribe(&mut self, topic: Topic) -> bool

Subscribe to a topic.

Returns true if the subscription worked. Returns false if we were already subscribed.

pub fn unsubscribe(&mut self, topic: Topic) -> bool

Unsubscribes from a topic.

Returns true if we were subscribed to this topic.

pub fn publish(&mut self, topic: &Topic, data: impl Into<Vec<u8>>)

Publishes a message to the network.

pub fn publish_many(
    &mut self,
    topic: impl IntoIterator<Item = Topic>,
    data: impl Into<Vec<u8>>
)

Publishes a message with multiple topics to the network.

pub fn propagate_message(
    &mut self,
    message_id: &MessageId,
    propagation_source: &PeerId
) -> bool

This function should be called when config.manual_propagation is true in order to propagate messages. Messages are stored in the ['Memcache'] and validation is expected to be fast enough that the messages should still exist in the cache.

Calling this function will propagate a message stored in the cache, if it still exists. If the message still exists in the cache, it will be forwarded and this function will return true, otherwise it will return false.

Trait Implementations

impl NetworkBehaviour for Gossipsub

type ProtocolsHandler = GossipsubHandler

Handler for all the protocols the network behaviour supports.

type OutEvent = GossipsubEvent

Event generated by the NetworkBehaviour and that the swarm will report back.

fn new_handler(&mut self) -> <Gossipsub as NetworkBehaviour>::ProtocolsHandler

Creates a new ProtocolsHandler for a connection with a peer.

fn addresses_of_peer(&mut self, &PeerId) -> Vec<Multiaddr>

Addresses that this behaviour is aware of for this specific peer, and that may allow reaching the peer.

fn inject_connected(&mut self, id: PeerId, ConnectedPoint)

Indicates the behaviour that we connected to the node with the given peer id through the given endpoint.

fn inject_disconnected(&mut self, id: &PeerId, ConnectedPoint)

Indicates the behaviour that we disconnected from the node with the given peer id. The endpoint is the one we used to be connected to.

fn inject_node_event(&mut self, propagation_source: PeerId, event: GossipsubRpc)

Informs the behaviour about an event generated by the handler dedicated to the peer identified by peer_id. for the behaviour.

fn poll(
    &mut self,
    cx: &mut Context,
    &mut impl PollParameters
) -> Poll<NetworkBehaviourAction<<<Gossipsub as NetworkBehaviour>::ProtocolsHandler as ProtocolsHandler>::InEvent, <Gossipsub as NetworkBehaviour>::OutEvent>>

Polls for things that swarm should do.

fn inject_replaced(
    &mut self,
    peer_id: PeerId,
    closed_endpoint: ConnectedPoint,
    new_endpoint: ConnectedPoint
)

Indicates the behaviour that we replace the connection from the node with another.

fn inject_addr_reach_failure(
    &mut self,
    _peer_id: Option<&PeerId>,
    _addr: &Multiaddr,
    _error: &dyn Error
)

Indicates to the behaviour that we tried to reach an address, but failed.

fn inject_dial_failure(&mut self, _peer_id: &PeerId)

Indicates to the behaviour that we tried to dial all the addresses known for a node, but failed.

fn inject_new_listen_addr(&mut self, _addr: &Multiaddr)

Indicates to the behaviour that we have started listening on a new multiaddr.

fn inject_expired_listen_addr(&mut self, _addr: &Multiaddr)

Indicates to the behaviour that a new multiaddr we were listening on has expired, which means that we are no longer listening in it.

fn inject_new_external_addr(&mut self, _addr: &Multiaddr)

Indicates to the behaviour that we have discovered a new external address for us.

fn inject_listener_error(
    &mut self,
    _id: ListenerId,
    _err: &(dyn Error + 'static)
)

A listener experienced an error.

fn inject_listener_closed(&mut self, _id: ListenerId)

A listener closed.