Skip to content

Commit

Permalink
Remodeling packages
Browse files Browse the repository at this point in the history
  • Loading branch information
cmendesce committed Feb 27, 2024
1 parent 2899bc1 commit 2d3c297
Show file tree
Hide file tree
Showing 10 changed files with 23 additions and 12 deletions.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package br.unifor.ppgia.resiliencebench;

import br.unifor.ppgia.resiliencebench.execution.Scheduler;
import br.unifor.ppgia.resiliencebench.resources.ExecutionQueueFactory;
import br.unifor.ppgia.resiliencebench.resources.ScenarioFactory;
import br.unifor.ppgia.resiliencebench.resources.benchmark.Benchmark;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution;

import br.unifor.ppgia.resiliencebench.execution.steps.IstioFaultStep;
import br.unifor.ppgia.resiliencebench.execution.steps.IstioRetryStep;
import br.unifor.ppgia.resiliencebench.execution.steps.K6LoadGeneratorStep;
import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import br.unifor.ppgia.resiliencebench.support.CustomResourceRepository;
import io.fabric8.istio.client.IstioClient;
Expand All @@ -10,12 +13,12 @@

import static java.lang.String.format;

public class ScenarioRunner2 {
public class ScenarioExecutor {

private final KubernetesClient kubernetesClient;
private final IstioClient istioClient;

public ScenarioRunner2(KubernetesClient kubernetesClient, IstioClient istioClient) {
public ScenarioExecutor(KubernetesClient kubernetesClient, IstioClient istioClient) {
this.istioClient = istioClient;
this.kubernetesClient = kubernetesClient;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
package br.unifor.ppgia.resiliencebench;
package br.unifor.ppgia.resiliencebench.execution;

import br.unifor.ppgia.resiliencebench.resources.queue.ExecutionQueue;
import br.unifor.ppgia.resiliencebench.resources.queue.Item;
import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import br.unifor.ppgia.resiliencebench.scenarioexec.ScenarioRunner2;
import br.unifor.ppgia.resiliencebench.support.CustomResourceRepository;
import io.fabric8.istio.client.DefaultIstioClient;
import io.fabric8.kubernetes.api.model.batch.v1.Job;
Expand Down Expand Up @@ -66,7 +65,7 @@ private boolean existsJobRunning(String namespace) {
}

private void createJob(String namespace, Item item) {
var runner = new ScenarioRunner2(this.client, new DefaultIstioClient());
var runner = new ScenarioExecutor(this.client, new DefaultIstioClient());
var job = runner.run(namespace, item.getScenario());
var jobsClient = client.batch().v1().jobs();
job = jobsClient.resource(job).create();
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import io.fabric8.kubernetes.api.model.HasMetadata;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import br.unifor.ppgia.resiliencebench.resources.service.ResilientService;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import br.unifor.ppgia.resiliencebench.resources.scenario.ScenarioFaultTemplate;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import io.fabric8.istio.api.networking.v1beta1.HTTPRetry;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import br.unifor.ppgia.resiliencebench.resources.scenario.ScenarioWorkload;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package br.unifor.ppgia.resiliencebench.scenarioexec;
package br.unifor.ppgia.resiliencebench.execution.steps;

import br.unifor.ppgia.resiliencebench.resources.scenario.Scenario;
import io.fabric8.kubernetes.client.KubernetesClient;
Expand Down

0 comments on commit 2d3c297

Please sign in to comment.