Struct fuel_core_p2p::config::Config

source ·
pub struct Config<State = Initialized> {
Show 29 fields pub keypair: Keypair, pub network_name: String, pub checksum: Checksum, pub address: IpAddr, pub public_address: Option<Multiaddr>, pub tcp_port: u16, pub max_block_size: usize, pub max_headers_per_request: u32, pub bootstrap_nodes: Vec<Multiaddr>, pub enable_mdns: bool, pub allow_private_addresses: bool, pub random_walk: Option<Duration>, pub connection_idle_timeout: Option<Duration>, pub reserved_nodes: Vec<Multiaddr>, pub reserved_nodes_only_mode: bool, pub max_peers_connected: u32, pub max_connections_per_peer: u32, pub identify_interval: Option<Duration>, pub info_interval: Option<Duration>, pub gossipsub_config: Config, pub heartbeat_config: Config, pub set_request_timeout: Duration, pub max_concurrent_streams: usize, pub set_connection_keep_alive: Duration, pub heartbeat_check_interval: Duration, pub heartbeat_max_avg_interval: Duration, pub heartbeat_max_time_since_last: Duration, pub metrics: bool, pub state: State,
}

Fields§

§keypair: Keypair

The keypair used for handshake during communication with other p2p nodes.

§network_name: String

Name of the Network

§checksum: Checksum

Checksum is a hash(sha256) of Genesis - chain id.

§address: IpAddr

IP address for Swarm to listen on

§public_address: Option<Multiaddr>

Optional address of your local node made reachable for other nodes in the network.

§tcp_port: u16

The TCP port that Swarm listens on

§max_block_size: usize

Max Size of a Block in bytes

§max_headers_per_request: u32§bootstrap_nodes: Vec<Multiaddr>§enable_mdns: bool§allow_private_addresses: bool§random_walk: Option<Duration>§connection_idle_timeout: Option<Duration>§reserved_nodes: Vec<Multiaddr>

Priority nodes that the node should maintain connection to

§reserved_nodes_only_mode: bool

Should the node only accept connection requests from the Reserved Nodes

§max_peers_connected: u32

Max number of unique peers connected This number should be at least number of mesh_n from Gossipsub configuration. The total number of connections will be (max_peers_connected + reserved_nodes.len()) * max_connections_per_peer

§max_connections_per_peer: u32

Max number of connections per single peer The total number of connections will be (max_peers_connected + reserved_nodes.len()) * max_connections_per_peer

§identify_interval: Option<Duration>

The interval at which identification requests are sent to the remote on established connections after the first request

§info_interval: Option<Duration>

The duration between the last successful outbound or inbound ping and the next outbound ping

§gossipsub_config: Config§heartbeat_config: Config§set_request_timeout: Duration

Sets the timeout for inbound and outbound requests.

§max_concurrent_streams: usize

Sets the maximum number of concurrent streams for a connection.

§set_connection_keep_alive: Duration

Sets the keep-alive timeout of idle connections.

§heartbeat_check_interval: Duration

Time between checking heartbeat status for all peers

§heartbeat_max_avg_interval: Duration

Max avg time between heartbeats for a given peer before getting reputation penalty

§heartbeat_max_time_since_last: Duration

Max time since a given peer has sent a heartbeat before getting reputation penalty

§metrics: bool

Enables prometheus metrics for this fuel-service

§state: State

It is the state of the config initialization. Everyone can create an instance of the Self with the NotInitialized state. But it can be set into the Initialized state only with the init method.

Implementations§

source§

impl Config<NotInitialized>

source

pub fn init(self, genesis: Genesis) -> Result<Config<Initialized>>

Inits the P2PConfig with some lazily loaded data.

source§

impl Config<NotInitialized>

source

pub fn default(network_name: &str) -> Self

Trait Implementations§

source§

impl<State: Clone> Clone for Config<State>

source§

fn clone(&self) -> Config<State>

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<State: Debug> Debug for Config<State>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<State> Freeze for Config<State>
where State: Freeze,

§

impl<State = Initialized> !RefUnwindSafe for Config<State>

§

impl<State> Send for Config<State>
where State: Send,

§

impl<State> Sync for Config<State>
where State: Sync,

§

impl<State> Unpin for Config<State>
where State: Unpin,

§

impl<State = Initialized> !UnwindSafe for Config<State>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> AnyDebug for T
where T: Any + Debug,

source§

fn as_any_ref(&self) -> &(dyn Any + 'static)

Returns a reference to the underlying type as Any.
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts 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 more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts 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
source§

impl<S> IteratorOverTable for S

source§

fn iter_all<M>( &self, direction: Option<IterDirection>, ) -> BoxedIter<'_, Result<(<M as Mappable>::OwnedKey, <M as Mappable>::OwnedValue), Error>>
where M: Mappable, Self: IterableTable<M>,

Returns an iterator over the all entries in the table.
source§

fn iter_all_by_prefix<M, P>( &self, prefix: Option<P>, ) -> BoxedIter<'_, Result<(<M as Mappable>::OwnedKey, <M as Mappable>::OwnedValue), Error>>
where M: Mappable, P: AsRef<[u8]>, Self: IterableTable<M>,

Returns an iterator over the all entries in the table with the specified prefix.
source§

fn iter_all_by_start<M>( &self, start: Option<&<M as Mappable>::Key>, direction: Option<IterDirection>, ) -> BoxedIter<'_, Result<(<M as Mappable>::OwnedKey, <M as Mappable>::OwnedValue), Error>>
where M: Mappable, Self: IterableTable<M>,

Returns an iterator over the all entries in the table after a specific start key.
source§

fn iter_all_filtered<M, P>( &self, prefix: Option<P>, start: Option<&<M as Mappable>::Key>, direction: Option<IterDirection>, ) -> BoxedIter<'_, Result<(<M as Mappable>::OwnedKey, <M as Mappable>::OwnedValue), Error>>
where M: Mappable, P: AsRef<[u8]>, Self: IterableTable<M>,

Returns an iterator over the all entries in the table with a prefix after a specific start key.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> StorageAsMut for T

source§

fn storage<Type>(&mut self) -> StorageMut<'_, Self, Type>
where Type: Mappable,

source§

fn storage_as_mut<Type>(&mut self) -> StorageMut<'_, Self, Type>
where Type: Mappable,

source§

impl<T> StorageAsRef for T

source§

fn storage<Type>(&self) -> StorageRef<'_, Self, Type>
where Type: Mappable,

source§

fn storage_as_ref<Type>(&self) -> StorageRef<'_, Self, Type>
where Type: Mappable,

source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more