feat(接口测试): 添加执行过程动态设置资源池线程数
This commit is contained in:
parent
15ff97a4cb
commit
fb4c715f98
|
@ -20,6 +20,7 @@ public class TaskRequestDTO implements Serializable {
|
||||||
private String kafkaConfig;
|
private String kafkaConfig;
|
||||||
private String minioConfig;
|
private String minioConfig;
|
||||||
private String queueId;
|
private String queueId;
|
||||||
|
private int poolSize;
|
||||||
/**
|
/**
|
||||||
* 是否需要实时接收单个步骤的结果
|
* 是否需要实时接收单个步骤的结果
|
||||||
*/
|
*/
|
||||||
|
|
|
@ -174,6 +174,7 @@ public class ApiExecuteService {
|
||||||
// 如果资源池配置了当前站点,则使用资源池的
|
// 如果资源池配置了当前站点,则使用资源池的
|
||||||
taskRequest.setMsUrl(testResourcePoolDTO.getServerUrl());
|
taskRequest.setMsUrl(testResourcePoolDTO.getServerUrl());
|
||||||
}
|
}
|
||||||
|
taskRequest.setPoolSize(testResourceNodeDTO.getConcurrentNumber());
|
||||||
|
|
||||||
// 将测试脚本缓存到 redis
|
// 将测试脚本缓存到 redis
|
||||||
String scriptRedisKey = getScriptRedisKey(reportId, testId);
|
String scriptRedisKey = getScriptRedisKey(reportId, testId);
|
||||||
|
|
Loading…
Reference in New Issue