diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-03-28 15:26:37 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2019-03-28 15:26:37 +0100 |
commit | 3981f83325702f0ae124e8d9cbaa1bf76eda79b1 (patch) | |
tree | 1e5429ac5899e4c0c5258c9d8bf8f7a8e90221bc /config-model | |
parent | 1ded1ef53b9b206770a765acbb097fb7c653463c (diff) | |
parent | 20137f39548cd2b2c5c5b826a0d8550e7c807e3e (diff) |
Merge branch 'master' into hmusum/use-separate-service-type-for-logserver-by-default
Diffstat (limited to 'config-model')
3 files changed, 14 insertions, 12 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/admin/Admin.java b/config-model/src/main/java/com/yahoo/vespa/model/admin/Admin.java index 8a98730c9c6..22811ae5878 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/admin/Admin.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/admin/Admin.java @@ -6,11 +6,9 @@ import com.yahoo.cloud.config.ZookeepersConfig; import com.yahoo.cloud.config.log.LogdConfig; import com.yahoo.config.application.api.DeployLogger; import com.yahoo.config.model.ConfigModelContext.ApplicationType; -import com.yahoo.config.model.api.ConfigServerSpec; import com.yahoo.config.model.deploy.DeployState; import com.yahoo.config.model.producer.AbstractConfigProducer; import com.yahoo.config.provision.ApplicationId; -import com.yahoo.config.provision.SystemName; import com.yahoo.config.provision.Zone; import com.yahoo.vespa.model.AbstractService; import com.yahoo.vespa.model.ConfigProxy; @@ -20,10 +18,8 @@ import com.yahoo.vespa.model.Logd; import com.yahoo.vespa.model.admin.clustercontroller.ClusterControllerContainerCluster; import com.yahoo.vespa.model.admin.metricsproxy.MetricsProxyContainer; import com.yahoo.vespa.model.admin.metricsproxy.MetricsProxyContainerCluster; -import com.yahoo.vespa.model.admin.monitoring.MetricsConsumer; import com.yahoo.vespa.model.admin.monitoring.Monitoring; import com.yahoo.vespa.model.admin.monitoring.builder.Metrics; -import com.yahoo.vespa.model.container.ContainerCluster; import com.yahoo.vespa.model.filedistribution.FileDistributionConfigProducer; import com.yahoo.vespa.model.filedistribution.FileDistributionConfigProvider; import com.yahoo.vespa.model.filedistribution.FileDistributor; @@ -32,7 +28,6 @@ import java.io.Serializable; import java.util.ArrayList; import java.util.Collections; import java.util.List; -import java.util.Map; import java.util.Optional; /** @@ -156,6 +151,7 @@ public class Admin extends AbstractConfigProducer implements Serializable { logserver(new LogdConfig.Logserver.Builder(). use(logServerContainerCluster.isPresent() || !isHostedVespa). host(logserver.getHostName()). + rpcport(logserver.getRelativePort(0)). port(logserver.getRelativePort(1))); } } diff --git a/config-model/src/main/java/com/yahoo/vespa/model/admin/Logserver.java b/config-model/src/main/java/com/yahoo/vespa/model/admin/Logserver.java index 0d641dcbd38..6c173043092 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/admin/Logserver.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/admin/Logserver.java @@ -9,6 +9,7 @@ import com.yahoo.vespa.model.AbstractService; * system. * * @author gjoranv + * @author bjorncs */ public class Logserver extends AbstractService { @@ -17,10 +18,10 @@ public class Logserver extends AbstractService { public Logserver(AbstractConfigProducer parent) { super(parent, "logserver"); - portsMeta.on(0).tag("unused"); - portsMeta.on(1).tag("logtp"); - portsMeta.on(2).tag("logtp").tag("telnet").tag("last-errors-holder"); - portsMeta.on(3).tag("logtp").tag("telnet").tag("replicator"); + portsMeta.on(0).tag("logtp").tag("rpc"); + portsMeta.on(1).tag("logtp").tag("legacy"); + portsMeta.on(2).tag("unused"); + portsMeta.on(3).tag("unused"); setProp("clustertype", "admin"); setProp("clustername", "admin"); } @@ -37,6 +38,8 @@ public class Logserver extends AbstractService { */ private String getMyJVMArgs() { StringBuilder sb = new StringBuilder(); + sb.append("-Dlogserver.rpcListenPort=").append(getRelativePort(0)); + sb.append(" "); sb.append("-Dlogserver.listenport=").append(getRelativePort(1)); sb.append(" "); sb.append("-Dlogserver.logarchive.dir=" + logArchiveDir); @@ -56,7 +59,7 @@ public class Logserver extends AbstractService { * @return 'true' always */ public boolean requiresWantedPort() { - return true; + return true; // TODO Support dynamic port allocation for logserver } /** @@ -68,7 +71,7 @@ public class Logserver extends AbstractService { @Override public String[] getPortSuffixes() { - return new String[]{ "unused", "logtp", "last.errors", "replicator" }; + return new String[]{ "rpc", "legacy", "unused/1", "unused/2" }; } } diff --git a/config-model/src/test/java/com/yahoo/vespa/model/admin/AdminTestCase.java b/config-model/src/test/java/com/yahoo/vespa/model/admin/AdminTestCase.java index 749ee2b9acc..6d65c2a472e 100644 --- a/config-model/src/test/java/com/yahoo/vespa/model/admin/AdminTestCase.java +++ b/config-model/src/test/java/com/yahoo/vespa/model/admin/AdminTestCase.java @@ -18,6 +18,7 @@ import com.yahoo.container.StatisticsConfig; import com.yahoo.container.jdisc.config.HealthMonitorConfig; import com.yahoo.net.HostName; import com.yahoo.vespa.config.core.StateserverConfig; +import com.yahoo.vespa.model.Service; import com.yahoo.vespa.model.VespaModel; import com.yahoo.vespa.model.container.ApplicationContainerCluster; import com.yahoo.vespa.model.container.component.Component; @@ -28,7 +29,6 @@ import org.junit.Test; import java.util.Set; -import static com.yahoo.config.model.api.container.ContainerServiceType.METRICS_PROXY_CONTAINER; import static org.hamcrest.CoreMatchers.is; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; @@ -94,6 +94,9 @@ public class AdminTestCase { LogdConfig lc = new LogdConfig(lb); assertEquals(lc.logserver().host(), localhost); + Service logserver = vespaModel.getService("admin/logserver").get(); + assertEquals(logserver.getRelativePort(0), lc.logserver().rpcport()); + // Verify services in the sentinel config SentinelConfig.Builder b = new SentinelConfig.Builder(); vespaModel.getConfig(b, localhostConfigId); |