def read_request_load_scenario(reactor, cluster, method='version', request_rate=10, sample_size=DEFAULT_SAMPLE_SIZE, timeout=45, tolerance_percentage=0.2):
 validate_no_arg_method(IFlockerAPIV1Client, method)
 request = getattr(cluster.get_control_service(reactor), method)
 return RequestLoadScenario(reactor, ReadRequest(request), request_rate=request_rate, sample_size=sample_size, timeout=timeout, tolerance_percentage=tolerance_percentage)

def read_request_load_scenario ( reactor , cluster , method = 'version' , request_rate = 10 , sample_size = DEFAULT_SAMPLE_SIZE , timeout = 45 , tolerance_percentage = 0.2 ) : validate_no_arg_method ( IFlockerAPIV1Client , method ) request = getattr ( cluster . get_control_service ( reactor ) , method ) return RequestLoadScenario ( reactor , ReadRequest ( request ) , request_rate = request_rate , sample_size = sample_size , timeout = timeout , tolerance_percentage = tolerance_percentage )
factory that will initialise and return an excenario that places load on the cluster by performing read requests at a specified rate .