Go through all stats entries and reset them to zero

A wrapper for self.client.request that: * Parses the JSON response to a dict called ``js`` in the response object. Marks the request

Emulates internodal messaging by calling registered listeners :param msg_type: The type of the message to emulate sending :p

Decorator for tagging tasks and TaskSets with the given tag name. You can then limit the test to only execute tasks that are tagged with any

Return the stats as a string suitable for console output. If current is True, it'll show the RPS and failure rate for the last 10 sec

Return the unserialzed version of the specified dict

Make the running user sleep for a duration defined by the Locust.wait_time function (or TaskSet.wait_time function if it's been defin

Construct Authorization header value to be used in HTTP Basic Auth

This function might take some time to complete if the `target_user_count` is a big number. A big number is typically > 50 000. Howeve

Validate single percentile value from .stats constants.

Generator based on Kullback-Leibler divergence For example, given users A, B with weights 5 and 1 respectively, this algorithm will yield AAA

When a rebalance is required because of added and/or removed workers, we compute the desired state as if we started from 0 user. So,

Remove user classes having a weight of zero.

Write requests csv data row, excluding header.

Round response time to reduce unique histogram keys. Rounds to ~2 significant digits, so that 147 becomes 150, 3432 becomes 3400 and 58760 be

Get the response time that a certain number of percent of the requests finished within. Arguments: response_times: A StatsEntry.response

Returns a function that will track the run time of the tasks, and for each time it's called it will return a wait time that will try to make

Adds the returned value (a dict) to the context for :ref:`request event <request_context>`. Override this in your User class to custo

Called at the end of the test

Generate a TLS cert and private key to serve over https

Sends a DELETE request

Sends a GET request

Function used by both TaskSetMeta and UserMeta for collecting all declared tasks on the TaskSet/User class and all its base classes

Determines if a task is a Markov task by checking if it has transitions defined. :param task: The task to check :return: True if the tas

Determines if a task is a MarkovTaskSet by checking its meta class Defined here to avoid circular imports. :param task: The task to chec

Check if path is an url

Parses the response as json and returns a dict

Called when a User stops executing this TaskSet. E.g. when TaskSet.interrupt() is called or when the User is killed

Sends a OPTIONS request

Construct a command line parser that is only used to parse the -f argument so that we can import the test scripts in case any of them adds ad

This function calculates the task ratio of users based on the user total count.

Publish a message to the MQTT broker. This method wraps the underlying paho-mqtt client's method in order to set up & fire Locust eve

Setup command-line options Takes a configargparse.ArgumentParser as argument and calls it's add_argument for each of the supported argum

Shut down locust by firing quitting event, printing/writing stats and exiting