Struct NoopNetwork 

#[non_exhaustive]
pub struct NoopNetwork<Net = EthNetworkPrimitives> { /* private fields */ }

A type that implements all network trait that does nothing.

Intended for testing purposes where network is not used.

Implementations

impl<Net> NoopNetwork<Net>

pub fn new() -> Self

Creates a new NoopNetwork.

pub const fn with_chain_id(self, chain_id: u64) -> Self

Creates a new NoopNetwork from an existing one but with a new chain id.

pub fn with_client_version(self, client_version: impl Into<String>) -> Self

Configures the client version returned by NetworkInfo::network_status.

Trait Implementations

impl<Net> BlockDownloaderProvider for NoopNetwork<Net>

where Net: NetworkPrimitives,

type Client = NoopFullBlockClient<Net>

The client this type can provide.

async fn fetch_client(&self) -> Result<Self::Client, RecvError>

Returns a new BlockClient, used for fetching blocks from peers.

impl<Net: Clone> Clone for NoopNetwork<Net>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Net: Debug> Debug for NoopNetwork<Net>

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

Formats the value using the given formatter.

impl Default for NoopNetwork<EthNetworkPrimitives>

fn default() -> Self

Returns the “default value” for a type.

impl<Net> NetworkEventListenerProvider for NoopNetwork<Net>

where Net: NetworkPrimitives,

type Primitives = Net

The primitive types to use in the PeerRequest used in the stream.

fn event_listener( &self, ) -> EventStream<NetworkEvent<PeerRequest<Self::Primitives>>>

Creates a new NetworkEvent listener channel.

fn discovery_listener(&self) -> UnboundedReceiverStream<DiscoveryEvent>

Returns a new DiscoveryEvent stream.

impl<Net> NetworkInfo for NoopNetwork<Net>

where Net: Send + Sync,

fn local_addr(&self) -> SocketAddr

Returns the SocketAddr that listens for incoming connections.

async fn network_status(&self) -> Result<NetworkStatus, NetworkError>

Returns the current status of the network being ran by the local node.

fn chain_id(&self) -> u64

Returns the chain id

fn cell_custody(&self) -> &CellCustody

Returns shared blob cell custody state for EIP-8070 sparse blobpool sampling.

fn is_syncing(&self) -> bool

Returns true if the network is undergoing sync.

fn is_initially_syncing(&self) -> bool

Returns true when the node is undergoing the very first Pipeline sync.

impl<Net> NetworkPeersEvents for NoopNetwork<Net>

where Net: NetworkPrimitives,

fn peer_events(&self) -> PeerEventStream

Creates a new peer event listener stream.

impl<Net> NetworkSyncUpdater for NoopNetwork<Net>

where Net: Debug + Send + Sync + 'static,

fn update_status(&self, _head: Head)

Updates the status of the p2p node.

fn update_sync_state(&self, _state: SyncState)

Notifies about a [SyncState] update.

fn update_block_range(&self, _: BlockRangeUpdate)

Updates the advertised block range.

fn set_fork_filter(&self, fork_filter: ForkFilter)

Replaces the node’s active [ForkFilter] to adopt a fork schedule that changed at runtime (e.g. an L1-signalled upgrade) without a restart.

impl<Net> Peers for NoopNetwork<Net>

where Net: Send + Sync,

fn add_trusted_peer_id(&self, _peer: PeerId)

Adds a trusted PeerId to the peer set.

fn add_peer_kind( &self, _peer: PeerId, _kind: Option<PeerKind>, _tcp_addr: SocketAddr, _udp_addr: Option<SocketAddr>, )

Adds a peer to the known peer set, with the given kind.

async fn get_peers_by_kind( &self, _kind: PeerKind, ) -> Result<Vec<PeerInfo>, NetworkError>

Returns the rpc PeerInfo for all connected peers with the given kind.

async fn get_all_peers(&self) -> Result<Vec<PeerInfo>, NetworkError>

Returns the rpc PeerInfo for all connected peers.

async fn get_peer_by_id( &self, _peer_id: PeerId, ) -> Result<Option<PeerInfo>, NetworkError>

Returns the rpc PeerInfo for the given peer id.

async fn get_peers_by_id( &self, _peer_id: Vec<PeerId>, ) -> Result<Vec<PeerInfo>, NetworkError>

Returns the rpc PeerInfo for the given peers if they are connected.

fn remove_peer(&self, _peer: PeerId, _kind: PeerKind)

Removes a peer from the peer set that corresponds to given kind.

fn disconnect_peer(&self, _peer: PeerId)

Disconnect an existing connection to the given peer.

fn disconnect_peer_with_reason(&self, _peer: PeerId, _reason: DisconnectReason)

Disconnect an existing connection to the given peer using the provided reason

fn ban_peer(&self, _peer: PeerId)

Bans the given peer and disconnects an active non-trusted session if one exists.

fn unban_peer(&self, _peer: PeerId)

Unbans the given peer.

fn connect_peer_kind( &self, _peer: PeerId, _kind: PeerKind, _tcp_addr: SocketAddr, _udp_addr: Option<SocketAddr>, )

Connects a peer to the known peer set, with the given kind.

fn reputation_change(&self, _peer_id: PeerId, _kind: ReputationChangeKind)

Send a reputation change for the given peer.

async fn reputation_by_id( &self, _peer_id: PeerId, ) -> Result<Option<Reputation>, NetworkError>

Get the reputation of a peer.

fn add_peer(&self, peer: PeerId, tcp_addr: SocketAddr)

Adds a peer to the peer set with TCP SocketAddr.

fn add_peer_with_udp( &self, peer: PeerId, tcp_addr: SocketAddr, udp_addr: SocketAddr, )

Adds a peer to the peer set with TCP and UDP SocketAddr.

fn add_trusted_peer(&self, peer: PeerId, tcp_addr: SocketAddr)

Adds a trusted peer to the peer set with TCP SocketAddr.

fn add_trusted_peer_with_udp( &self, peer: PeerId, tcp_addr: SocketAddr, udp_addr: SocketAddr, )

Adds a trusted peer with TCP and UDP SocketAddr to the peer set.

fn add_trusted_peer_node(&self, _peer: TrustedPeer)

Registers a trusted peer that may use a hostname instead of an IP address.

fn get_trusted_peers( &self, ) -> impl Future<Output = Result<Vec<PeerInfo>, NetworkError>> + Send

Returns the rpc PeerInfo for all connected PeerKind::Trusted peers.

fn get_basic_peers( &self, ) -> impl Future<Output = Result<Vec<PeerInfo>, NetworkError>> + Send

Returns the rpc PeerInfo for all connected PeerKind::Basic peers.

fn connect_peer(&self, peer: PeerId, tcp_addr: SocketAddr)

Connect to the given peer. NOTE: if the maximum number of outbound sessions is reached, this won’t do anything. See reth_network::SessionManager::dial_outbound.

impl<Net> PeersHandleProvider for NoopNetwork<Net>

where Net: NetworkPrimitives,

fn peers_handle(&self) -> &PeersHandle

Returns the PeersHandle that can be cloned and shared.

impl<Net> PeersInfo for NoopNetwork<Net>

where Net: Send + Sync,

fn num_connected_peers(&self) -> usize

Returns how many peers the network is currently connected to.

fn local_node_record(&self) -> NodeRecord

Returns the Ethereum Node Record of the node.

fn local_enr(&self) -> Enr<SecretKey>

Returns the local ENR of the node.

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: 48 bytes