Struct HyperGenerator

pub struct HyperGenerator<S: Scenario> {
    pub scenario: S,
    pub request: HttpConfig,
    pub max_open_connections: usize,
    /* private fields */
}

A hyper based generator. This generator use’s HTTP multiplexing, and requires that the target server supports HTTP2. Much like the reqwest generator, HyperGenerator 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

request: HttpConfig

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.

Implementations

impl<S: Scenario> HyperGenerator<S>

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

Constructs a new HyperGenerator

Trait Implementations

impl<T: Scenario> TrafficGenerator<T> for HyperGenerator<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).