crows 0.3.0

CLI for using the Crows stress testing tool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crows::output::drive_progress;
use crows_utils::services::CoordinatorClient;

pub async fn start(
    coordinator: &mut CoordinatorClient,
    name: &str,
    workers_number: &usize,
) -> anyhow::Result<()> {
    let (run_id, mut worker_names) = coordinator
        .start(name.to_string(), workers_number.clone())
        .await
        .unwrap()
        .unwrap();

    worker_names.sort();

    drive_progress(coordinator, &run_id, worker_names)
        .await
        .expect("Error while running a scenario");

    Ok(())
}