Function bench_client

pub unsafe fn bench_client<'a, Client>(
    clients: &Cluster<'a, Client>,
    transaction_cycle: impl FnOnce(Stream<(u32, u32), Cluster<'a, Client>, Unbounded>) -> Stream<(u32, u32), Cluster<'a, Client>, Unbounded, NoOrder>,
    num_clients_per_node: usize,
) -> BenchResult<'a, Client>

Benchmarks transactional workloads by concurrently submitting workloads (up to num_clients_per_node per machine), measuring the latency of each transaction and throughput over the entire workload.

Safety

This function uses non-deterministic time-based samples, and also updates results at non-deterministic points in time.