diff options
author | gjoranv <gv@verizonmedia.com> | 2019-05-21 17:35:13 +0200 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2019-05-22 00:33:42 +0200 |
commit | f8252529b76a6a384873248e9e016ea5f325fad7 (patch) | |
tree | f74ab3361b921f8711e1b1c425ee0666caf0f650 /config-model/src/test | |
parent | 92eb53f4954f17ab560b25dbf33be7b80343a453 (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.java | 27 |
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 |