Struct hotshot_testing::test_runner::TestRunner

pub struct TestRunner<TYPES: NodeType, I: TestableNodeImplementation<TYPES>, V: Versions, N: ConnectedNetwork<TYPES::SignatureKey>> {
    pub(crate) launcher: TestLauncher<TYPES, I, V>,
    pub(crate) nodes: Vec<Node<TYPES, I, V>>,
    pub(crate) solver_server: Option<(Url, JoinHandle<()>)>,
    pub(crate) late_start: HashMap<u64, LateStartNode<TYPES, I, V>>,
    pub(crate) next_node_id: u64,
    pub(crate) _pd: PhantomData<N>,
}

The runner of a test network spin up and down nodes, execute rounds

Fields

launcher: TestLauncher<TYPES, I, V>

test launcher, contains a bunch of useful metadata and closures

nodes: Vec<Node<TYPES, I, V>>

nodes in the test

solver_server: Option<(Url, JoinHandle<()>)>

the solver server running in the test

late_start: HashMap<u64, LateStartNode<TYPES, I, V>>

nodes with a late start

next_node_id: u64

the next node unique identifier

_pd: PhantomData<N>

Phantom for N

Implementations

impl<TYPES: NodeType<InstanceState = TestInstanceState, ValidatedState = TestValidatedState, BlockHeader = TestBlockHeader>, I, V: Versions, N: ConnectedNetwork<TYPES::SignatureKey>> TestRunner<TYPES, I, V, N>

where I: TestableNodeImplementation<TYPES> + NodeImplementation<TYPES, Network = N, Storage = TestStorage<TYPES>, AuctionResultsProvider = TestAuctionResultsProvider<TYPES>>,

pub async fn run_test<B: TestBuilderImplementation<TYPES>>(self)

execute test

Panics

if the test fails

pub async fn init_builders<B: TestBuilderImplementation<TYPES>>( &self, num_nodes: usize, ) -> (Vec<Box<dyn BuilderTask<TYPES>>>, Vec<Url>, Url)

pub async fn add_solver(&mut self, builder_urls: Vec<Url>)

Add auction solver.

pub async fn add_nodes<B: TestBuilderImplementation<TYPES>>( &mut self, total: usize, late_start: &HashSet<u64>, restart: &HashSet<u64>, ) -> Vec<u64>

Add nodes.

Panics

Panics if unable to create a HotShotInitializer

pub async fn add_node_with_config( node_id: u64, network: Network<TYPES, I>, memberships: TYPES::Membership, initializer: HotShotInitializer<TYPES>, config: HotShotConfig<TYPES::SignatureKey>, validator_config: ValidatorConfig<TYPES::SignatureKey>, storage: I::Storage, marketplace_config: MarketplaceConfig<TYPES, I>, ) -> Arc<SystemContext<TYPES, I, V>>

add a specific node with a config

Panics

if unable to initialize the node’s SystemContext based on the config

pub async fn add_node_with_config_and_channels( node_id: u64, network: Network<TYPES, I>, memberships: Arc<RwLock<TYPES::Membership>>, initializer: HotShotInitializer<TYPES>, config: HotShotConfig<TYPES::SignatureKey>, validator_config: ValidatorConfig<TYPES::SignatureKey>, storage: I::Storage, marketplace_config: MarketplaceConfig<TYPES, I>, internal_channel: (Sender<Arc<HotShotEvent<TYPES>>>, Receiver<Arc<HotShotEvent<TYPES>>>), external_channel: (Sender<Event<TYPES>>, Receiver<Event<TYPES>>), ) -> Arc<SystemContext<TYPES, I, V>>

add a specific node with a config

Panics

if unable to initialize the node’s SystemContext based on the config