Struct StressRun 

pub struct StressRun { /* private fields */ }

Configuration for a stress run.

Example

use dev_stress::StressRun;

let run = StressRun::new("hot_path").iterations(1_000).threads(4);
assert_eq!(run.iterations_planned(), 1_000);
assert_eq!(run.threads_planned(), 4);

Implementations

impl StressRun

pub fn new(name: impl Into<String>) -> Self

Begin building a stress run with a stable name.

pub fn iterations(self, n: usize) -> Self

Total iterations across all threads.

pub fn threads(self, n: usize) -> Self

Number of OS threads to run concurrently. Minimum is 1.

pub fn track_latency(self, rate: usize) -> Self

Track per-operation latency, sampling 1 of every rate iterations.

rate = 1 records every iteration; rate = 100 records 1% of iterations. Lower rates lower memory and overhead at the cost of percentile precision.

Example

use dev_stress::StressRun;

let run = StressRun::new("hot").iterations(10_000).threads(2)
    .track_latency(10); // 10% sample rate
assert_eq!(run.iterations_planned(), 10_000);

pub fn iterations_planned(&self) -> usize

The configured iteration count.

pub fn threads_planned(&self) -> usize

The configured thread count.

pub fn execute<W>(&self, workload: &W) -> StressResult

where W: Workload + Clone + 'static,

Execute the run. Returns a result with timing statistics.