Struct SoakRun 

pub struct SoakRun { /* private fields */ }

Configuration for a soak run.

Example

use dev_stress::SoakRun;
use std::time::Duration;

let run = SoakRun::new("steady_state")
    .duration(Duration::from_millis(500))
    .checkpoint(Duration::from_millis(100))
    .threads(2);

Implementations

impl SoakRun

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

Begin building a soak run with a stable name.

pub fn duration(self, d: Duration) -> Self

Total wall-clock duration the soak runs for.

pub fn checkpoint(self, d: Duration) -> Self

Wall-clock interval between checkpoints.

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

Number of OS threads. Minimum is 1.

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

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

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

where W: Workload + Clone + 'static,

Execute the soak run.

Returns when total_duration has elapsed. Threads observe a shared stop flag and finish their current iteration before joining.