Struct reth_network::PeersConfig
pub struct PeersConfig {
pub refill_slots_interval: Duration,
pub trusted_nodes: Vec<TrustedPeer>,
pub trusted_nodes_only: bool,
pub max_backoff_count: u8,
pub basic_nodes: HashSet<NodeRecord>,
pub ban_duration: Duration,
pub ban_list: BanList,
pub connection_info: ConnectionsConfig,
pub reputation_weights: ReputationChangeWeights,
pub backoff_durations: PeerBackoffDurations,
}
Expand description
Config type for initiating a PeersManager
instance.
Fields§
§refill_slots_interval: Duration
How often to recheck free slots for outbound connections.
trusted_nodes: Vec<TrustedPeer>
Trusted nodes to connect to or accept from
trusted_nodes_only: bool
Connect to or accept from trusted nodes only?
max_backoff_count: u8
Maximum number of backoff attempts before we give up on a peer and dropping.
The max time spent of a peer before it’s removed from the set is determined by the configured backoff duration and the max backoff count.
With a backoff counter of 5 and a backoff duration of 1h, the minimum time spent of the peer in the table is the sum of all backoffs (1h + 2h + 3h + 4h + 5h = 15h).
Note: this does not apply to trusted peers.
basic_nodes: HashSet<NodeRecord>
Basic nodes to connect to.
ban_duration: Duration
How long to ban bad peers.
ban_list: BanList
Restrictions on PeerIds
and Ips.
connection_info: ConnectionsConfig
Restrictions on connections.
reputation_weights: ReputationChangeWeights
How to weigh reputation changes.
backoff_durations: PeerBackoffDurations
How long to backoff peers that we are failed to connect to for non-fatal reasons.
The backoff duration increases with number of backoff attempts.
Implementations§
§impl PeersConfig
impl PeersConfig
pub fn with_ban_list(self, ban_list: BanList) -> PeersConfig
pub fn with_ban_list(self, ban_list: BanList) -> PeersConfig
A set of peer_ids
and ip addr that we want to never connect to
pub const fn with_ban_duration(self, ban_duration: Duration) -> PeersConfig
pub const fn with_ban_duration(self, ban_duration: Duration) -> PeersConfig
Configure how long to ban bad peers
pub const fn with_max_outbound(self, max_outbound: usize) -> PeersConfig
pub const fn with_max_outbound(self, max_outbound: usize) -> PeersConfig
Maximum allowed outbound connections.
pub const fn with_max_inbound_opt(
self,
max_inbound: Option<usize>,
) -> PeersConfig
pub const fn with_max_inbound_opt( self, max_inbound: Option<usize>, ) -> PeersConfig
Maximum allowed inbound connections with optional update.
pub const fn with_max_outbound_opt(
self,
max_outbound: Option<usize>,
) -> PeersConfig
pub const fn with_max_outbound_opt( self, max_outbound: Option<usize>, ) -> PeersConfig
Maximum allowed outbound connections with optional update.
pub const fn with_max_inbound(self, max_inbound: usize) -> PeersConfig
pub const fn with_max_inbound(self, max_inbound: usize) -> PeersConfig
Maximum allowed inbound connections.
pub const fn with_max_concurrent_dials(
self,
max_concurrent_outbound_dials: usize,
) -> PeersConfig
pub const fn with_max_concurrent_dials( self, max_concurrent_outbound_dials: usize, ) -> PeersConfig
Maximum allowed concurrent outbound dials.
pub fn with_trusted_nodes(self, nodes: Vec<TrustedPeer>) -> PeersConfig
pub fn with_trusted_nodes(self, nodes: Vec<TrustedPeer>) -> PeersConfig
Nodes to always connect to.
pub const fn with_trusted_nodes_only(self, trusted_only: bool) -> PeersConfig
pub const fn with_trusted_nodes_only(self, trusted_only: bool) -> PeersConfig
Connect only to trusted nodes.
pub fn with_basic_nodes(self, nodes: HashSet<NodeRecord>) -> PeersConfig
pub fn with_basic_nodes(self, nodes: HashSet<NodeRecord>) -> PeersConfig
Nodes available at launch.
pub const fn with_max_backoff_count(self, max_backoff_count: u8) -> PeersConfig
pub const fn with_max_backoff_count(self, max_backoff_count: u8) -> PeersConfig
Configures the max allowed backoff count.
pub const fn with_reputation_weights(
self,
reputation_weights: ReputationChangeWeights,
) -> PeersConfig
pub const fn with_reputation_weights( self, reputation_weights: ReputationChangeWeights, ) -> PeersConfig
Configures how to weigh reputation changes.
pub const fn with_backoff_durations(
self,
backoff_durations: PeerBackoffDurations,
) -> PeersConfig
pub const fn with_backoff_durations( self, backoff_durations: PeerBackoffDurations, ) -> PeersConfig
Configures how long to backoff peers that are we failed to connect to for non-fatal reasons
pub fn with_basic_nodes_from_file(
self,
optional_file: Option<impl AsRef<Path>>,
) -> Result<PeersConfig, Error>
pub fn with_basic_nodes_from_file( self, optional_file: Option<impl AsRef<Path>>, ) -> Result<PeersConfig, Error>
Read from file nodes available at launch. Ignored if None.
pub fn test() -> PeersConfig
Available on crate feature test-utils
only.
pub fn test() -> PeersConfig
test-utils
only.Returns settings for testing
Trait Implementations§
§impl Clone for PeersConfig
impl Clone for PeersConfig
§fn clone(&self) -> PeersConfig
fn clone(&self) -> PeersConfig
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more§impl Debug for PeersConfig
impl Debug for PeersConfig
§impl Default for PeersConfig
impl Default for PeersConfig
§fn default() -> PeersConfig
fn default() -> PeersConfig
§impl<'de> Deserialize<'de> for PeersConfigwhere
PeersConfig: Default,
impl<'de> Deserialize<'de> for PeersConfigwhere
PeersConfig: Default,
§fn deserialize<__D>(
__deserializer: __D,
) -> Result<PeersConfig, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<PeersConfig, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
§impl PartialEq for PeersConfig
impl PartialEq for PeersConfig
§impl Serialize for PeersConfig
impl Serialize for PeersConfig
§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
impl Eq for PeersConfig
impl StructuralPartialEq for PeersConfig
Auto Trait Implementations§
impl Freeze for PeersConfig
impl RefUnwindSafe for PeersConfig
impl Send for PeersConfig
impl Sync for PeersConfig
impl Unpin for PeersConfig
impl UnwindSafe for PeersConfig
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Conv for T
impl<T> Conv for T
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.§impl<T> TryConv for T
impl<T> TryConv for T
§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
source§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
source§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
source§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
impl<T> MaybeDebug for Twhere
T: Debug,
impl<T> NippyJarHeader for T
impl<T> RpcObject for Twhere
T: RpcParam + RpcReturn,
impl<T> RpcParam for T
impl<T> RpcReturn for T
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...)
attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 328 bytes