Struct sc_network_test::TestNet

pub struct TestNet { /* private fields */ }

Trait Implementations

impl Default for TestNet

fn default() -> TestNet

Returns the “default value” for a type.

impl TestNetFactory for TestNet

type Verifier = PassThroughVerifier

type PeerData = ()

type BlockImport = PeersClient

fn make_verifier(&self, _client: PeersClient, _peer_data: &()) -> Self::Verifier

This one needs to be implemented!

fn make_block_import( &self, client: PeersClient ) -> (BlockImportAdapter<Self::BlockImport>, Option<BoxJustificationImport<Block>>, Self::PeerData)

Get custom block import handle for fresh client, along with peer data.

fn peer(&mut self, i: usize) -> &mut Peer<(), Self::BlockImport>

Get reference to peer.

fn peers(&self) -> &Vec<Peer<(), Self::BlockImport>>

fn peers_mut(&mut self) -> &mut Vec<Peer<(), Self::BlockImport>>

fn mut_peers<F: FnOnce(&mut Vec<Peer<(), Self::BlockImport>>)>( &mut self, closure: F )

fn new(n: usize) -> Self

Create new test network with this many peers.

fn add_full_peer(&mut self)

fn add_full_peer_with_config(&mut self, config: FullPeerConfig)

Add a full peer.

fn spawn_task(&self, f: BoxFuture<'static, ()>)

Used to spawn background tasks, e.g. the block request protocol handler.

fn poll_until_connected(&mut self, cx: &mut FutureContext<'_>) -> Poll<()>

Polls the testnet until all peers are connected to each other.

fn is_in_sync<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn is_idle<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn run_until_sync<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Blocks the current thread until we are sync’ed. Wait until we are sync’ed.

fn run_until_idle<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Run the network until there are no pending packets.

fn run_until_connected<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Run the network until all peers are connected to each other.

fn poll(&mut self, cx: &mut FutureContext<'_>)

Polls the testnet. Processes all the pending actions.