From 5bc2de7087a4de349d409bab1064c9e92edaf5b5 Mon Sep 17 00:00:00 2001 From: Carlos Mendes Date: Tue, 18 Jun 2024 00:06:59 -0300 Subject: [PATCH] Adding destination to retry --- .../execution/istio/steps/IstioRetryStep.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/resilience-bench/operator/src/main/java/io/resiliencebench/execution/istio/steps/IstioRetryStep.java b/resilience-bench/operator/src/main/java/io/resiliencebench/execution/istio/steps/IstioRetryStep.java index bf86c05..ae0ef8e 100644 --- a/resilience-bench/operator/src/main/java/io/resiliencebench/execution/istio/steps/IstioRetryStep.java +++ b/resilience-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();