Adding destination to retry

ppgia-unifor · Jun 18, 2024 · 5bc2de7 · 5bc2de7
1 parent 28426dd
commit 5bc2de7
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/...bench/operator/src/main/java/io/resiliencebench/execution/istio/steps/IstioRetryStep.java b/...bench/operator/src/main/java/io/resiliencebench/execution/istio/steps/IstioRetryStep.java
@@ -38,12 +38,9 @@ private void configureRetryOnSource(String namespace, Source source, Target targ
     var sourceVirtualService = findVirtualService(namespace, source.getServiceName());
     var retryPolicy = createRetryPolicy(source.getPatternConfig(), target);
     if (retryPolicy.isPresent()) {
-      Destination destination = new DestinationBuilder()
-              .withHost(target.getServiceName())
-              .withSubset("v1")
-              .build();
+      var destination = new DestinationBuilder().withHost(target.getServiceName()).build();
 
-      HTTPRoute httpRoute = new HTTPRouteBuilder()
+      var httpRoute = new HTTPRouteBuilder()
               .withRoute(Collections.singletonList(new HTTPRouteDestinationBuilder()
                       .withDestination(destination)
                       .build()))
@@ -53,7 +50,7 @@ private void configureRetryOnSource(String namespace, Source source, Target targ
       var newVirtualService = sourceVirtualService
               .edit()
               .editSpec()
-              .withHttp(Collections.singletonList(httpRoute))
+              .withHttp(httpRoute)
               .endSpec()
               .build();