Module network

Re-exported from reth_network.

Modules

cache

Network cache support

config

Network config support

error

Possible errors when interacting with the network.

eth_requests

Blocks/Headers management for the p2p network.

import

This module provides an abstraction over block import in the form of the BlockImport trait.

message

Capability messaging

noop

Implementation of network traits for that does nothing. A network implementation that does nothing.

p2p

Provides abstractions and commonly used types for p2p.

peers

Peer related implementations

protocol

Support for handling additional RLPx-based application-level protocols.

test_utils

Common helpers for network testing. Common helpers for network testing.

transactions

Transactions management for the p2p network.

types

Types for the eth wire protocol: https://github.com/ethereum/devp2p/blob/master/caps/eth.md

Macros

duration_metered_exec

Measures the duration of executing the given code block. The duration is added to the given accumulator value passed as a mutable reference.

metered_poll_nested_stream_with_budget

Metered poll of the given stream. Breaks with true if there maybe is more work.

poll_nested_stream_with_budget

Polls the given stream. Breaks with true if there maybe is more work.

Structs

ActiveSessionHandle

An established session with a remote peer.

Discovery

An abstraction over the configured discovery protocol.

EthNetworkPrimitives

Network primitive types used by Ethereum networks.

FetchClient

Front-end API for fetching data from the network.

FlattenedResponse

Flatten a [Receiver] message in order to get rid of the [RecvError] result

HelloMessageWithProtocols

This is a superset of [HelloMessage] that provides additional protocol [Protocol] information about the number of messages used by each capability in order to do proper message ID multiplexing.

MessageFilter

Wrapper for types that implement FilterAnnouncement. The definition of a valid announcement is network dependent. For example, different networks support different TxTypes, and different TxTypes have different transaction size constraints. Defaults to EthMessageFilter.

NetworkBuilder

A builder that can configure all components of the network.

NetworkConfig

All network related initialization settings.

NetworkConfigBuilder

Builder for NetworkConfig.

NetworkHandle

A shareable network frontend. Used to interact with the network.

NetworkManager

Manages the entire state of the network.

PeerInfo

Info about an active peer session.

PeerRequestSender

A Cloneable connection for sending requests directly to the session of a peer.

PeersConfig

Config type for initiating a PeersManager instance.

PendingSessionHandle

A handler attached to a peer session that’s not authenticated yet, pending Handshake and hello message which exchanges the capabilities of the peer.

SessionId

Internal identifier for active sessions.

SessionManager

Manages a set of sessions.

SessionsConfig

Configuration options for peer session management.

TxTypesCounter

Counts the number of transactions by their type in a block or collection.

Enums

ActiveSessionMessage

Message variants an active session can produce and send back to the SessionManager

Direction

The direction of the connection.

DisconnectReason

RLPx disconnect reason.

DiscoveredEvent

Represents events related to peer discovery in the network.

DiscoveryEvent

Events produced by the Discovery manager.

EthRlpxConnection

Connection types that support the ETH protocol.

NetworkConnectionState

Represents the state of the connection of the node. If shutting down, new connections won’t be established. When in hibernation mode, the node will not initiate new outbound connections. This is beneficial for sync stages that do not require a network connection.

NetworkEvent

(Non-exhaustive) Network events representing peer lifecycle events and session requests.

PeerRequest

Protocol related request messages that expect a response

PendingSessionEvent

Events a pending session can produce.

PendingSessionHandshakeError

Errors that can occur during handshaking/authenticating the underlying streams.

SessionCommand

Commands that can be sent to the spawned session.

SessionEvent

Events produced by the SessionManager

SyncState

The state the network is currently in when it comes to synchronization.

Traits

BlockDownloaderProvider

Provides client for downloading blocks.

FilterAnnouncement

Filters valid entries in NewPooledTransactionHashes68 and NewPooledTransactionHashes66 in place, and flags misbehaving peers.

NetworkEventListenerProvider

Provides event subscription for the network.

NetworkInfo

Provides general purpose information about the network.

NetworkPrimitives

Abstraction over primitive types which might appear in network messages. See crate::EthMessage for more context.

NetworkProtocols

Provides access to modify the network’s additional protocol handlers.

NetworkSyncUpdater

An updater for updating the SyncState and status of the network.

Peers

Provides an API for managing the peers of the network.

PeersHandleProvider

Provides an API for managing the peers of the network.

PeersInfo

Provides general purpose information about Peers in the network.

ValidateTx68

Interface for validating a (ty, size, hash) tuple from a NewPooledTransactionHashes68..