aboutsummaryrefslogtreecommitdiffstats
path: root/config-model/src/test
diff options
context:
space:
mode:
authorgjoranv <gv@verizonmedia.com>2019-05-21 17:35:13 +0200
committergjoranv <gv@verizonmedia.com>2019-05-22 00:33:42 +0200
commitf8252529b76a6a384873248e9e016ea5f325fad7 (patch)
treef74ab3361b921f8711e1b1c425ee0666caf0f650 /config-model/src/test
parent92eb53f4954f17ab560b25dbf33be7b80343a453 (diff)
Enable admin rpc server on metricsproxy containers.
Diffstat (limited to 'config-model/src/test')
-rw-r--r--config-model/src/test/java/com/yahoo/vespa/model/admin/metricsproxy/MetricsProxyContainerTest.java27
1 files changed, 20 insertions, 7 deletions
diff --git a/config-model/src/test/java/com/yahoo/vespa/model/admin/metricsproxy/MetricsProxyContainerTest.java b/config-model/src/test/java/com/yahoo/vespa/model/admin/metricsproxy/MetricsProxyContainerTest.java
index ff486c6a437..a1b77332bd2 100644
--- a/config-model/src/test/java/com/yahoo/vespa/model/admin/metricsproxy/MetricsProxyContainerTest.java
+++ b/config-model/src/test/java/com/yahoo/vespa/model/admin/metricsproxy/MetricsProxyContainerTest.java
@@ -60,19 +60,32 @@ public class MetricsProxyContainerTest {
}
@Test
- public void rpc_server_is_running_on_expected_port() {
+ public void metrics_rpc_server_is_running_on_expected_port() {
VespaModel model = getModel(servicesWithContent());
-
MetricsProxyContainer container = (MetricsProxyContainer)model.id2producer().get(CONTAINER_CONFIG_ID);
- int rpcPort = container.metricsRpcPortOffset();
- assertTrue(container.getPortsMeta().getTagsAt(rpcPort).contains("rpc"));
- assertTrue(container.getPortsMeta().getTagsAt(rpcPort).contains("metrics"));
+ int offset = container.metricsRpcPortOffset();
+ assertEquals(2, container.getPortsMeta().getTagsAt(offset).size());
+ assertTrue(container.getPortsMeta().getTagsAt(offset).contains("rpc"));
+ assertTrue(container.getPortsMeta().getTagsAt(offset).contains("metrics"));
- assertEquals("rpc/metrics", container.getPortSuffixes()[rpcPort]);
+ assertEquals("rpc/metrics", container.getPortSuffixes()[offset]);
RpcConnectorConfig config = getRpcConnectorConfig(model);
- assertEquals(19094, config.port());
+ assertEquals(19095, config.port());
+ }
+
+ @Test
+ public void admin_rpc_server_is_running() {
+ VespaModel model = getModel(servicesWithContent());
+ MetricsProxyContainer container = (MetricsProxyContainer)model.id2producer().get(CONTAINER_CONFIG_ID);
+
+ int offset = container.metricsRpcPortOffset() - 1;
+ assertEquals(2, container.getPortsMeta().getTagsAt(offset).size());
+ assertTrue(container.getPortsMeta().getTagsAt(offset).contains("rpc"));
+ assertTrue(container.getPortsMeta().getTagsAt(offset).contains("admin"));
+
+ assertEquals("rpc/admin", container.getPortSuffixes()[offset]);
}
@Test