Struct libp2p_gossipsub::ConfigBuilder

source ·

pub struct ConfigBuilder { /* private fields */ }

Expand description

The builder struct for constructing a gossipsub configuration.

Implementations§

source §

impl ConfigBuilder

source

pub fn protocol_id_prefix( &mut self, protocol_id_prefix: impl Into<Cow<'static, str>> ) -> &mut Self

The protocol id prefix to negotiate this protocol (default is /meshsub/1.1.0 and /meshsub/1.0.0).

source

pub fn protocol_id( &mut self, protocol_id: impl Into<Cow<'static, str>>, custom_id_version: Version ) -> &mut Self

The full protocol id to negotiate this protocol (does not append /1.0.0 or /1.1.0).

source

pub fn history_length(&mut self, history_length: usize) -> &mut Self

Number of heartbeats to keep in the memcache (default is 5).

source

pub fn history_gossip(&mut self, history_gossip: usize) -> &mut Self

Number of past heartbeats to gossip about (default is 3).

source

pub fn mesh_n(&mut self, mesh_n: usize) -> &mut Self

Target number of peers for the mesh network (D in the spec, default is 6).

source

pub fn mesh_n_low(&mut self, mesh_n_low: usize) -> &mut Self

Minimum number of peers in mesh network before adding more (D_lo in the spec, default is 4).

source

pub fn mesh_n_high(&mut self, mesh_n_high: usize) -> &mut Self

Maximum number of peers in mesh network before removing some (D_high in the spec, default is 12).

source

pub fn retain_scores(&mut self, retain_scores: usize) -> &mut Self

Affects how peers are selected when pruning a mesh due to over subscription.

At least Self::retain_scores of the retained peers will be high-scoring, while the remainder are chosen randomly (D_score in the spec, default is 4).

source

pub fn gossip_lazy(&mut self, gossip_lazy: usize) -> &mut Self

Minimum number of peers to emit gossip to during a heartbeat (D_lazy in the spec, default is 6).

source

pub fn gossip_factor(&mut self, gossip_factor: f64) -> &mut Self

Affects how many peers we will emit gossip to at each heartbeat.

We will send gossip to gossip_factor * (total number of non-mesh peers), or gossip_lazy, whichever is greater. The default is 0.25.

source

pub fn heartbeat_initial_delay( &mut self, heartbeat_initial_delay: Duration ) -> &mut Self

Initial delay in each heartbeat (default is 5 seconds).

source

pub fn heartbeat_interval(&mut self, heartbeat_interval: Duration) -> &mut Self

Time between each heartbeat (default is 1 second).

source

pub fn check_explicit_peers_ticks( &mut self, check_explicit_peers_ticks: u64 ) -> &mut Self

The number of heartbeat ticks until we recheck the connection to explicit peers and reconnecting if necessary (default 300).

source

pub fn fanout_ttl(&mut self, fanout_ttl: Duration) -> &mut Self

Time to live for fanout peers (default is 60 seconds).

source

pub fn max_transmit_size(&mut self, max_transmit_size: usize) -> &mut Self

The maximum byte size for each gossip (default is 2048 bytes).

source

pub fn idle_timeout(&mut self, idle_timeout: Duration) -> &mut Self

The time a connection is maintained to a peer without being in the mesh and without send/receiving a message from. Connections that idle beyond this timeout are disconnected. Default is 120 seconds.

source

pub fn duplicate_cache_time(&mut self, cache_size: Duration) -> &mut Self

Duplicates are prevented by storing message id’s of known messages in an LRU time cache. This settings sets the time period that messages are stored in the cache. Duplicates can be received if duplicate messages are sent at a time greater than this setting apart. The default is 1 minute.

source

pub fn validate_messages(&mut self) -> &mut Self

When set, prevents automatic forwarding of all received messages. This setting allows a user to validate the messages before propagating them to their peers. If set, the user must manually call crate::Behaviour::report_message_validation_result() on the behaviour to forward a message once validated.

source

pub fn validation_mode(&mut self, validation_mode: ValidationMode) -> &mut Self

Determines the level of validation used when receiving messages. See ValidationMode for the available types. The default is ValidationMode::Strict.

source

pub fn message_id_fn<F>(&mut self, id_fn: F) -> &mut Selfwhere F: Fn(&Message) -> MessageId + Send + Sync + 'static,

A user-defined function allowing the user to specify the message id of a gossipsub message. The default value is to concatenate the source peer id with a sequence number. Setting this parameter allows the user to address packets arbitrarily. One example is content based addressing, where this function may be set to hash(message). This would prevent messages of the same content from being duplicated.

The function takes a Message as input and outputs a String to be interpreted as the message id.

source

pub fn fast_message_id_fn<F>(&mut self, fast_id_fn: F) -> &mut Selfwhere F: Fn(&RawMessage) -> FastMessageId + Send + Sync + 'static,

A user-defined optional function that computes fast ids from raw messages. This can be used to avoid possibly expensive transformations from RawMessage to Message for duplicates. Two semantically different messages must always have different fast message ids, but it is allowed that two semantically identical messages have different fast message ids as long as the message_id_fn produces the same id for them.

The function takes a Message as input and outputs a String to be interpreted as the fast message id. Default is None.

source

pub fn do_px(&mut self) -> &mut Self

Enables Peer eXchange. This should be enabled in bootstrappers and other well connected/trusted nodes. The default is false.

Note: Peer exchange is not implemented today, see https://github.com/libp2p/rust-libp2p/issues/2398.

source

pub fn prune_peers(&mut self, prune_peers: usize) -> &mut Self

Controls the number of peers to include in prune Peer eXchange.

When we prune a peer that’s eligible for PX (has a good score, etc), we will try to send them signed peer records for up to [Self::prune_peers] other peers that we know of. It is recommended that this value is larger than [Self::mesh_n_high`] so that the pruned peer can reliably form a full mesh. The default is 16.

source

pub fn prune_backoff(&mut self, prune_backoff: Duration) -> &mut Self

Controls the backoff time for pruned peers. This is how long a peer must wait before attempting to graft into our mesh again after being pruned. When pruning a peer, we send them our value of Self::prune_backoff so they know the minimum time to wait. Peers running older versions may not send a backoff time, so if we receive a prune message without one, we will wait at least Self::prune_backoff before attempting to re-graft. The default is one minute.

source

pub fn unsubscribe_backoff(&mut self, unsubscribe_backoff: u64) -> &mut Self

Controls the backoff time when unsubscribing from a topic.

This is how long to wait before resubscribing to the topic. A short backoff period in case of an unsubscribe event allows reaching a healthy mesh in a more timely manner. The default is 10 seconds.

source

pub fn backoff_slack(&mut self, backoff_slack: u32) -> &mut Self

Number of heartbeat slots considered as slack for backoffs. This gurantees that we wait at least backoff_slack heartbeats after a backoff is over before we try to graft. This solves problems occuring through high latencies. In particular if backoff_slack * heartbeat_interval is longer than any latencies between processing prunes on our side and processing prunes on the receiving side this guarantees that we get not punished for too early grafting. The default is 1.

source

pub fn flood_publish(&mut self, flood_publish: bool) -> &mut Self

Whether to do flood publishing or not. If enabled newly created messages will always be sent to all peers that are subscribed to the topic and have a good enough score. The default is true.

source

pub fn graft_flood_threshold( &mut self, graft_flood_threshold: Duration ) -> &mut Self

If a GRAFT comes before graft_flood_threshold has elapsed since the last PRUNE, then there is an extra score penalty applied to the peer through P7.

source

pub fn mesh_outbound_min(&mut self, mesh_outbound_min: usize) -> &mut Self

Minimum number of outbound peers in the mesh network before adding more (D_out in the spec). This value must be smaller or equal than mesh_n / 2 and smaller than mesh_n_low. The default is 2.

source

pub fn opportunistic_graft_ticks( &mut self, opportunistic_graft_ticks: u64 ) -> &mut Self

Number of heartbeat ticks that specifcy the interval in which opportunistic grafting is applied. Every opportunistic_graft_ticks we will attempt to select some high-scoring mesh peers to replace lower-scoring ones, if the median score of our mesh peers falls below a threshold (see https://godoc.org/github.com/libp2p/go-libp2p-pubsub#PeerScoreThresholds). The default is 60.

source

pub fn gossip_retransimission( &mut self, gossip_retransimission: u32 ) -> &mut Self

Controls how many times we will allow a peer to request the same message id through IWANT gossip before we start ignoring them. This is designed to prevent peers from spamming us with requests and wasting our resources.

source

pub fn opportunistic_graft_peers( &mut self, opportunistic_graft_peers: usize ) -> &mut Self

The maximum number of new peers to graft to during opportunistic grafting. The default is 2.

source

pub fn max_messages_per_rpc(&mut self, max: Option<usize>) -> &mut Self

The maximum number of messages we will process in a given RPC. If this is unset, there is no limit. The default is None.

source

pub fn max_ihave_length(&mut self, max_ihave_length: usize) -> &mut Self

The maximum number of messages to include in an IHAVE message. Also controls the maximum number of IHAVE ids we will accept and request with IWANT from a peer within a heartbeat, to protect from IHAVE floods. You should adjust this value from the default if your system is pushing more than 5000 messages in GossipSubHistoryGossip heartbeats; with the defaults this is 1666 messages/s. The default is 5000.

source

pub fn max_ihave_messages(&mut self, max_ihave_messages: usize) -> &mut Self

GossipSubMaxIHaveMessages is the maximum number of IHAVE messages to accept from a peer within a heartbeat.

source

pub fn allow_self_origin(&mut self, allow_self_origin: bool) -> &mut Self

By default, gossipsub will reject messages that are sent to us that has the same message source as we have specified locally. Enabling this, allows these messages and prevents penalizing the peer that sent us the message. Default is false.

source

pub fn iwant_followup_time( &mut self, iwant_followup_time: Duration ) -> &mut Self

Time to wait for a message requested through IWANT following an IHAVE advertisement. If the message is not received within this window, a broken promise is declared and the router may apply behavioural penalties. The default is 3 seconds.

source