Struct Gossip 

pub struct Gossip(/* private fields */);

Available on crate feature net only.

Publish and subscribe on gossiping topics.

Each topic is a separate broadcast tree with separate memberships. A topic has to be joined before you can publish or subscribe on the topic. To join the swarm for a topic, you have to know the [NodeId] of at least one peer that also joined the topic.

Messages published on the swarm will be delivered to all peers that joined the swarm for that topic. You will also be relaying (gossiping) messages published by other peers.

With the default settings, the protocol will maintain up to 5 peer connections per topic.

Even though the Gossip is created from a [Endpoint], it does not accept connections itself. You should run an accept loop on the [Endpoint] yourself, check the ALPN protocol of incoming connections, and if the ALPN protocol equals GOSSIP_ALPN, forward the connection to the gossip actor through Self::handle_connection.

The gossip actor will, however, initiate new connections to other peers by itself.

Implementations

impl Gossip

pub fn builder() -> Builder

Creates a default Builder, with the endpoint set.

pub async fn listen(self, endpoint: Endpoint)

Available on crate feature rpc only.

Listen on a quinn endpoint for incoming RPC connections.

pub fn max_message_size(&self) -> usize

Get the maximum message size configured for this gossip actor.

pub async fn handle_connection( &self, remote: NodeId, connection: Connection, ) -> Result<(), ActorStoppedError>

Handle an incoming [Connection].

Make sure to check the ALPN protocol yourself before passing the connection.

pub fn metrics(&self) -> &Arc<Metrics>

Returns the metrics tracked for this gossip instance.

Methods from Deref<Target = GossipApi>

pub async fn subscribe_with_opts( &self, topic_id: TopicId, opts: JoinOptions, ) -> Result<GossipTopic, ApiError>

Available on crate features net or rpc only.

Join a gossip topic with options.

Returns a GossipTopic instantly. To wait for at least one connection to be established, you can await GossipTopic::joined.

Messages will be queued until a first connection is available. If the internal channel becomes full, the oldest messages will be dropped from the channel.

pub async fn subscribe_and_join( &self, topic_id: TopicId, bootstrap: Vec<NodeId>, ) -> Result<GossipTopic, ApiError>

Available on crate features net or rpc only.

Join a gossip topic with the default options and wait for at least one active connection.

pub async fn subscribe( &self, topic_id: TopicId, bootstrap: Vec<NodeId>, ) -> Result<GossipTopic, ApiError>

Available on crate features net or rpc only.

Join a gossip topic with the default options.

Note that this will not wait for any bootstrap node to be available. To ensure the topic is connected to at least one node, use GossipTopic::joined or Self::subscribe_and_join

Trait Implementations

impl Clone for Gossip

fn clone(&self) -> Gossip

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Gossip

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for Gossip

type Target = GossipApi

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl ProtocolHandler for Gossip

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

Handle an incoming connection.

async fn shutdown(&self)

Called when the router shuts down.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.