This commit is contained in:
Captain.B 2020-04-29 17:50:25 +08:00
parent 563a16a0cf
commit 7f965302ad
2 changed files with 13 additions and 0 deletions

View File

@ -90,6 +90,7 @@ public class KubernetesTestEngine extends AbstractEngine {
jmeter.setSpec(new JmeterSpec() {{ jmeter.setSpec(new JmeterSpec() {{
setReplicas(1); setReplicas(1);
setImage(JMETER_IMAGE); setImage(JMETER_IMAGE);
setEnv(context.getEnv());
}}); }});
LogUtil.info("Load test started. " + context.getTestId()); LogUtil.info("Load test started. " + context.getTestId());
kubernetesProvider.applyCustomResource(jmeter); kubernetesProvider.applyCustomResource(jmeter);

View File

@ -4,11 +4,15 @@ import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize; import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import io.fabric8.kubernetes.api.model.KubernetesResource; import io.fabric8.kubernetes.api.model.KubernetesResource;
import java.util.HashMap;
import java.util.Map;
@JsonDeserialize @JsonDeserialize
@JsonInclude(JsonInclude.Include.NON_EMPTY) @JsonInclude(JsonInclude.Include.NON_EMPTY)
public class JmeterSpec implements KubernetesResource { public class JmeterSpec implements KubernetesResource {
private int replicas = 1; private int replicas = 1;
private String image; private String image;
private Map<String, String> env = new HashMap<>();
public int getReplicas() { public int getReplicas() {
return replicas; return replicas;
@ -25,4 +29,12 @@ public class JmeterSpec implements KubernetesResource {
public void setImage(String image) { public void setImage(String image) {
this.image = image; this.image = image;
} }
public Map<String, String> getEnv() {
return env;
}
public void setEnv(Map<String, String> env) {
this.env = env;
}
} }