summaryrefslogtreecommitdiffstats
path: root/orchestrator
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-05 10:34:07 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-01-25 10:48:48 +0100
commitd8a3a7bf6d9685db965833064876d8ed02ed0699 (patch)
tree40a5491e1187a075d1a9c0b000bb9de2f215560e /orchestrator
parentf8338e1ea64c58a7986f929a4c3c229b92a8cfde (diff)
VespaHttpClientBuilder follow builder pattern and add connect and socket timeout to builder.
Diffstat (limited to 'orchestrator')
-rw-r--r--orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java12
1 files changed, 8 insertions, 4 deletions
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java
index 479d6bfe079..5bd4e03642e 100644
--- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java
+++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java
@@ -8,6 +8,7 @@ import com.yahoo.component.annotation.Inject;
import com.yahoo.component.AbstractComponent;
import com.yahoo.vespa.applicationmodel.HostName;
import org.apache.hc.core5.http.message.BasicHeader;
+import org.apache.hc.core5.util.Timeout;
import java.io.IOException;
import java.util.List;
@@ -25,10 +26,13 @@ public class RetryingClusterControllerClientFactory extends AbstractComponent im
@Inject
public RetryingClusterControllerClientFactory() {
- this(AbstractHttpClient.wrapping(VespaHttpClientBuilder.create()
- .setUserAgent("orchestrator-cluster-controller-client")
- .setDefaultHeaders(List.of(new BasicHeader("Accept", "application/json")))
- .build()));
+ this(AbstractHttpClient.wrapping(VespaHttpClientBuilder
+ .custom()
+ .setConnectTimeout(Timeout.ofSeconds(5))
+ .build()
+ .setUserAgent("orchestrator-cluster-controller-client")
+ .setDefaultHeaders(List.of(new BasicHeader("Accept", "application/json")))
+ .build()));
}
RetryingClusterControllerClientFactory(HttpClient client) {