summaryrefslogtreecommitdiffstats
path: root/orchestrator
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@oath.com>2017-11-21 12:49:29 +0100
committerBjørn Christian Seime <bjorncs@oath.com>2017-11-21 13:25:26 +0100
commita5e9e72054f596110f5fbff7970139af853b2610 (patch)
treef61195c41b145ed81549fa42b3a8d67bbb07e2c9 /orchestrator
parent437dfe2db270af3ce8c4da1975ce335bb625f557 (diff)
Set scheme parameter for all us of jaxrs client
Diffstat (limited to 'orchestrator')
-rw-r--r--orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/RetryingClusterControllerClientFactory.java3
-rw-r--r--orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactory.java4
-rw-r--r--orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactoryTest.java7
3 files changed, 10 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 e0f5b0ecf4f..c7aae6ea93d 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
@@ -20,6 +20,7 @@ public class RetryingClusterControllerClientFactory implements ClusterController
// TODO: Figure this port out dynamically.
public static final int HARDCODED_CLUSTERCONTROLLER_PORT = 19050;
public static final String CLUSTERCONTROLLER_API_PATH = "/";
+ public static final String CLUSTERCONTROLLER_SCHEME = "http";
private static final int CLUSTER_CONTROLLER_CONNECT_TIMEOUT_MS = 1000;
private static final int CLUSTER_CONTROLLER_READ_TIMEOUT_MS = 1000;
@@ -39,7 +40,7 @@ public class RetryingClusterControllerClientFactory implements ClusterController
String clusterName) {
Set<HostName> clusterControllerSet = clusterControllers.stream().collect(Collectors.toSet());
JaxRsStrategy<ClusterControllerJaxRsApi> jaxRsApi
- = new JaxRsStrategyFactory(clusterControllerSet, HARDCODED_CLUSTERCONTROLLER_PORT, jaxRsClientFactory)
+ = new JaxRsStrategyFactory(clusterControllerSet, HARDCODED_CLUSTERCONTROLLER_PORT, jaxRsClientFactory, CLUSTERCONTROLLER_SCHEME)
.apiWithRetries(ClusterControllerJaxRsApi.class, CLUSTERCONTROLLER_API_PATH);
return new ClusterControllerClientImpl(jaxRsApi, clusterName);
}
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactory.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactory.java
index ca757adfea3..7459f0a6b11 100644
--- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactory.java
+++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactory.java
@@ -16,6 +16,7 @@ import java.util.logging.Logger;
public class SingleInstanceClusterControllerClientFactory implements ClusterControllerClientFactory {
public static final int CLUSTERCONTROLLER_HARDCODED_PORT = 19050;
+ public static final String CLUSTERCONTROLLER_HARDCODED_SCHEME = "http";
public static final String CLUSTERCONTROLLER_API_PATH = "/";
private static final Logger log = Logger.getLogger(SingleInstanceClusterControllerClientFactory.class.getName());
@@ -44,7 +45,8 @@ public class SingleInstanceClusterControllerClientFactory implements ClusterCont
port,
jaxRsClientFactory,
ClusterControllerJaxRsApi.class,
- CLUSTERCONTROLLER_API_PATH);
+ CLUSTERCONTROLLER_API_PATH,
+ CLUSTERCONTROLLER_HARDCODED_SCHEME);
return new ClusterControllerClientImpl(strategy, clusterName);
}
diff --git a/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactoryTest.java b/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactoryTest.java
index aaddb01197c..b26d11a113f 100644
--- a/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactoryTest.java
+++ b/orchestrator/src/test/java/com/yahoo/vespa/orchestrator/controller/SingleInstanceClusterControllerClientFactoryTest.java
@@ -43,6 +43,7 @@ public class SingleInstanceClusterControllerClientFactoryTest {
eq(ClusterControllerJaxRsApi.class),
any(HostName.class),
anyInt(),
+ anyString(),
anyString()))
.thenReturn(mockApi);
}
@@ -70,7 +71,8 @@ public class SingleInstanceClusterControllerClientFactoryTest {
ClusterControllerJaxRsApi.class,
HOST_NAME_1,
PORT,
- PATH);
+ PATH,
+ "http");
}
@Test
@@ -99,7 +101,8 @@ public class SingleInstanceClusterControllerClientFactoryTest {
equalTo(HOST_NAME_2),
equalTo(HOST_NAME_3)))),
eq(PORT),
- eq(PATH));
+ eq(PATH),
+ eq("http"));
}
private static ConfigId clusterControllerConfigId(final int index) {