Struct trawler::WorkloadBuilder

pub struct WorkloadBuilder<'a> { /* fields omitted */ }

Set the parameters for a new Lobsters-like workload.

Implementations

impl<'a> WorkloadBuilder<'a>

pub fn scale(&mut self, factor: f64) -> &mut Self

Set the scaling factor for the workload.

A factor of 1 generates a workload commensurate with what the real lobste.rs sees. At scale 1, the site starts out with ~40k stories with a total of ~300k comments spread across 9k users. The generated load is on average 44 requests/minute, with a request distribution set according to the one observed on lobste.rs (see data/ for details).

pub fn time(&mut self, warmup: Duration, runtime: Duration) -> &mut Self

Set the runtime for the benchmark.

pub fn in_flight(&mut self, max: usize) -> &mut Self

The maximum number of outstanding request any single issuer is allowed to have to the backend. Defaults to 20.

pub fn with_histogram<'this>(&'this mut self, path: &'a str) -> &'this mut Self

Instruct the load generator to store raw histogram data of request latencies into the given file upon completion.

If the given file exists at the start of the benchmark, the existing histograms will be amended, not replaced.

impl<'a> WorkloadBuilder<'a>

pub fn run<MS>(&self, client: MS, prime: bool) where
    MS: MakeService<bool, TrawlerRequest>,
    MS::MakeError: Debug,
    <MS::Service as Service<TrawlerRequest>>::Future: Send + 'static,
    MS::Error: Debug + Send + 'static,
    MS::Response: Send + 'static,
    MS::Service: AsyncShutdown, 

Run this workload with clients spawned from the given factory.

If prime is true, the database will be seeded with stories and comments according to the scaling factory before the benchmark starts. If the site has already been primed, there is no need to prime again unless the backend is emptied or the scaling factor is changed. Note that priming does not delete the database, nor detect the current scaling factor, so always empty the backend before calling run with prime set.

The provided client must be able to (asynchronously) create a Service<TrawlerRequest>. To do so, it must implement Service<bool>, where the boolean parameter indicates whether the database is also scheduled to be primed before the workload begins.

Trait Implementations

impl<'a> Default for WorkloadBuilder<'a>

fn default() -> Self

Returns the "default value" for a type.