Struct pdc_core::generator::reqwest_generator::ReqwestGenerator

pub struct ReqwestGenerator<S: Scenario> {
    pub scenario: S,
    pub max_open_connections: usize,
    pub warmup: bool,
    pub req: Request,
    /* private fields */
}

Very simple reqwest based generator. This generator does not use HTTP multiplexing and is very sensitive to latency. For good proformance, it is recommended to test servers running on the same LAN as your machine. This Generator will reuse TCP connections for requests, and all request will be sent from the same IP.

Fields

scenario: S

max_open_connections: usize

This is the maximum amount of TCP file descriptors being used at any one time. The actual number of open connections will be higher, because it takes time to purge old fd’s.

warmup: bool

Let this generator warm up to the rate at t=0 before sending test data.

req: Request

The request to send.

Implementations

impl<S: Scenario> ReqwestGenerator<S>

pub fn new(
    scenario: S,
    max_open_connections: usize,
    worker_count: usize,
    warmup: bool,
    req: Request
) -> Self

Constructs a new ReqwestGenerator

Trait Implementations

impl<T: Scenario> TrafficGenerator<T> for ReqwestGenerator<T>

fn run_scenario(&mut self)

Runs the current scenario

fn fire_hose(&mut self)

Run the generator at full throttle!

fn set_scenario(&mut self, schem: T)

Sets a Scenario for the generator to try and replicate.

fn get_scenario(&self) -> &T

Gets the current Scenario

fn send_packet(&mut self)

Send a single packet per call, used for debuging and low traffic testing.

fn get_data_rate_channel(&self) -> Receiver<(f32, f32)>

Give a bounded channel that sends time series data on the send rate of a generator. The data is encoded as (Miliseconds since start of scenario, counts/sec).

fn get_sent_packets_channel(&self) -> Receiver<usize>

Give a bounded channel that sends the total amount of packets/requests sent

fn get_error_rate_channel(&self) -> Receiver<(f32, f32)>

Give a bounded channel that sends time series data on the send rate of a generator. The data is encoded as (Miliseconds since start of scenario, counts/sec).