summaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-07-08 10:54:47 +0200
committerHarald Musum <musum@yahooinc.com>2022-07-08 10:54:47 +0200
commit3a74ca9a999bdec5b00332aaa9cb53c8e01743cc (patch)
tree05056bbf7b81dd6271f5dac0641dc85be94c1b29 /config-model/src/main/java/com/yahoo
parent06e43f9f3f3aa65917a8ce84c6b0efefe0465f62 (diff)
Minor cleanup, no functional changes
Diffstat (limited to 'config-model/src/main/java/com/yahoo')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/admin/Admin.java19
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminBuilderBase.java12
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java44
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV4Builder.java6
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java2
5 files changed, 34 insertions, 49 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 79f65264249..1928fb0f9ad 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
@@ -79,19 +79,19 @@ public class Admin extends AbstractConfigProducer<Admin> implements Serializable
private ZooKeepersConfigProvider zooKeepersConfigProvider;
private final FileDistributionConfigProducer fileDistribution;
- private final boolean multitenant;
+ private final boolean multiTenant;
public Admin(AbstractConfigProducer<?> parent,
Monitoring monitoring,
Metrics metrics,
- boolean multitenant,
+ boolean multiTenant,
boolean isHostedVespa,
ApplicationType applicationType) {
super(parent, "admin");
this.isHostedVespa = isHostedVespa;
this.monitoring = monitoring;
this.metrics = metrics;
- this.multitenant = multitenant;
+ this.multiTenant = multiTenant;
this.fileDistribution = new FileDistributionConfigProducer(parent);
this.applicationType = applicationType;
}
@@ -149,7 +149,7 @@ public class Admin extends AbstractConfigProducer<Admin> implements Serializable
public void setClusterControllers(ClusterControllerContainerCluster clusterControllers, DeployState deployState) {
this.clusterControllers = clusterControllers;
if (isHostedVespa) {
- // Prefer to put Slobroks on the admin cluster running cluster controllers to avoid unnecessary
+ // Prefer to put slobroks on the admin cluster running cluster controllers to avoid unnecessary
// movement of the slobroks when there are changes to the content cluster nodes
removeSlobroks();
addSlobroks(createSlobroksOn(clusterControllers, deployState));
@@ -250,9 +250,9 @@ public class Admin extends AbstractConfigProducer<Admin> implements Serializable
boolean actuallyAdd = true;
var membership = host.spec().membership();
if (membership.isPresent()) {
- var clustertype = membership.get().cluster().type();
+ var clusterType = membership.get().cluster().type();
// XXX should skip only if this.isHostedVespa is true?
- if (clustertype == ClusterSpec.Type.admin) {
+ if (clusterType == ClusterSpec.Type.admin) {
actuallyAdd = logForwarderIncludeAdmin;
}
}
@@ -263,8 +263,7 @@ public class Admin extends AbstractConfigProducer<Admin> implements Serializable
}
private void addConfigSentinel(DeployState deployState, HostResource host,
- ApplicationId applicationId, Zone zone, ModelContext.FeatureFlags featureFlags)
- {
+ ApplicationId applicationId, Zone zone, ModelContext.FeatureFlags featureFlags) {
ConfigSentinel configSentinel = new ConfigSentinel(host.getHost(), applicationId, zone, featureFlags);
addAndInitializeService(deployState, host, configSentinel);
host.getHost().setConfigSentinel(configSentinel);
@@ -320,9 +319,7 @@ public class Admin extends AbstractConfigProducer<Admin> implements Serializable
return slobs;
}
- public boolean multitenant() {
- return multitenant;
- }
+ public boolean multiTenant() { return multiTenant; }
public ApplicationType getApplicationType() { return applicationType; }
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminBuilderBase.java b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminBuilderBase.java
index 4c74282c061..c3bfeca91ae 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminBuilderBase.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminBuilderBase.java
@@ -1,7 +1,6 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.builder.xml.dom;
-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;
@@ -20,7 +19,6 @@ import com.yahoo.vespa.model.admin.monitoring.builder.Metrics;
import com.yahoo.vespa.model.admin.monitoring.builder.PredefinedMetricSets;
import com.yahoo.vespa.model.admin.monitoring.builder.xml.MetricsBuilder;
import org.w3c.dom.Element;
-
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
@@ -35,13 +33,11 @@ public abstract class DomAdminBuilderBase extends VespaDomBuilder.DomConfigProdu
private final ApplicationType applicationType;
protected final List<ConfigServerSpec> configServerSpecs;
- protected final boolean multitenant;
+ protected final boolean multiTenant;
- DomAdminBuilderBase(ApplicationType applicationType,
- boolean multitenant,
- List<ConfigServerSpec> configServerSpecs) {
+ DomAdminBuilderBase(ApplicationType applicationType, boolean multiTenant, List<ConfigServerSpec> configServerSpecs) {
this.applicationType = applicationType;
- this.multitenant = multitenant;
+ this.multiTenant = multiTenant;
this.configServerSpecs = configServerSpecs;
}
@@ -65,7 +61,7 @@ public abstract class DomAdminBuilderBase extends VespaDomBuilder.DomConfigProdu
Monitoring monitoring = getMonitoring(XML.getChild(adminElement,"monitoring"), deployState.isHosted());
Metrics metrics = new MetricsBuilder(applicationType, PredefinedMetricSets.get())
.buildMetrics(XML.getChild(adminElement, "metrics"));
- Admin admin = new Admin(parent, monitoring, metrics, multitenant, deployState.isHosted(), applicationType);
+ Admin admin = new Admin(parent, monitoring, metrics, multiTenant, deployState.isHosted(), applicationType);
doBuildAdmin(deployState, admin, adminElement);
new ModelConfigProvider(admin);
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java
index e081848d01c..68e34f7bf06 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java
@@ -1,7 +1,7 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.builder.xml.dom;
-import com.yahoo.config.model.ConfigModelContext;
+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;
@@ -17,7 +17,6 @@ import com.yahoo.vespa.model.admin.clustercontroller.ClusterControllerContainerC
import com.yahoo.vespa.model.builder.xml.dom.VespaDomBuilder.DomConfigProducerBuilder;
import com.yahoo.vespa.model.container.Container;
import org.w3c.dom.Element;
-
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
@@ -32,45 +31,39 @@ public class DomAdminV2Builder extends DomAdminBuilderBase {
private static final String ATTRIBUTE_CLUSTER_CONTROLLER_STANDALONE_ZK = "standalone-zookeeper";
- public DomAdminV2Builder(ConfigModelContext.ApplicationType applicationType,
- boolean multitenant,
- List<ConfigServerSpec> configServerSpecs) {
- super(applicationType, multitenant, configServerSpecs);
+ public DomAdminV2Builder(ApplicationType applicationType, boolean multiTenant, List<ConfigServerSpec> configServerSpecs) {
+ super(applicationType, multiTenant, configServerSpecs);
}
@Override
protected void doBuildAdmin(DeployState deployState, Admin admin, Element adminE) {
- List<Configserver> configservers = parseConfigservers(deployState, admin, adminE);
admin.setLogserver(parseLogserver(deployState, admin, adminE));
- admin.addConfigservers(configservers);
+ admin.addConfigservers(parseConfigServers(deployState, admin, adminE));
admin.addSlobroks(getSlobroks(deployState, admin, XML.getChild(adminE, "slobroks")));
- if ( ! admin.multitenant())
+ if ( ! admin.multiTenant())
admin.setClusterControllers(addConfiguredClusterControllers(deployState, admin, adminE), deployState);
-
addLogForwarders(new ModelElement(adminE).child("logforwarding"), admin);
}
- private List<Configserver> parseConfigservers(DeployState deployState, Admin admin, Element adminE) {
- List<Configserver> configservers;
- if (multitenant)
- configservers = getConfigServersFromSpec(deployState, admin);
- else
- configservers = getConfigServers(deployState, admin, adminE);
- if (configservers.isEmpty() && ! multitenant)
- configservers = createSingleConfigServer(deployState, admin);
- if (configservers.size() % 2 == 0)
+ private List<Configserver> parseConfigServers(DeployState deployState, Admin admin, Element adminE) {
+ List<Configserver> configServers = multiTenant
+ ? getConfigServersFromSpec(deployState, admin)
+ : getConfigServers(deployState, admin, adminE);
+
+ if (configServers.isEmpty() && !multiTenant)
+ configServers = createSingleConfigServer(deployState, admin);
+ if (configServers.size() % 2 == 0)
deployState.getDeployLogger().logApplicationPackage(Level.WARNING,
- "An even number (" + configservers.size() +
+ "An even number (" + configServers.size() +
") of config servers have been configured. " +
"This is discouraged, see doc for configuration server ");
- return configservers;
+ return configServers;
}
private Logserver parseLogserver(DeployState deployState, Admin admin, Element adminE) {
Element logserverE = XML.getChild(adminE, "logserver");
- if (logserverE == null) {
+ if (logserverE == null)
logserverE = XML.getChild(adminE, "adminserver");
- }
return new LogserverBuilder().build(deployState, admin, logserverE);
}
@@ -83,10 +76,9 @@ public class DomAdminV2Builder extends DomAdminBuilderBase {
List<Element> controllers = XML.getChildren(controllersElements, "cluster-controller");
if (controllers.isEmpty()) return null;
- boolean standaloneZooKeeper = "true".equals(controllersElements.getAttribute(ATTRIBUTE_CLUSTER_CONTROLLER_STANDALONE_ZK)) || multitenant;
- if (standaloneZooKeeper) {
+ boolean standaloneZooKeeper = "true".equals(controllersElements.getAttribute(ATTRIBUTE_CLUSTER_CONTROLLER_STANDALONE_ZK)) || multiTenant;
+ if (standaloneZooKeeper)
parent = new ClusterControllerCluster(parent, "standalone", deployState);
- }
var cluster = new ClusterControllerContainerCluster(parent,
"cluster-controllers",
"cluster-controllers",
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV4Builder.java b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV4Builder.java
index dae2f7e8cb8..b6ee08cb5ec 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV4Builder.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV4Builder.java
@@ -33,9 +33,9 @@ public class DomAdminV4Builder extends DomAdminBuilderBase {
private final Collection<ContainerModel> containerModels;
private final ConfigModelContext context;
- public DomAdminV4Builder(ConfigModelContext context, boolean multitenant, List<ConfigServerSpec> configServerSpecs,
+ public DomAdminV4Builder(ConfigModelContext context, boolean multiTenant, List<ConfigServerSpec> configServerSpecs,
Collection<ContainerModel> containerModels) {
- super(context.getApplicationType(), multitenant, configServerSpecs);
+ super(context.getApplicationType(), multiTenant, configServerSpecs);
this.containerModels = containerModels;
this.context = context;
}
@@ -131,7 +131,7 @@ public class DomAdminV4Builder extends DomAdminBuilderBase {
* The list returns the same nodes on each invocation given the same available nodes.
*
* @param count the desired number of nodes. More nodes may be returned to ensure a smooth transition
- * on topology changes, and less nodes may be returned if fewer are available
+ * on topology changes, and fewer nodes may be returned if fewer are available
* @param minHostsPerContainerCluster the desired number of hosts per cluster
*/
private List<HostResource> pickContainerHostsForSlobrok(int count, int minHostsPerContainerCluster) {
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java
index 776d23e5227..7f262b4aee7 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java
@@ -287,7 +287,7 @@ public class ContentCluster extends AbstractConfigProducer<AbstractConfigProduce
if (context.properties().hostedVespa()) {
clusterControllers = getDedicatedSharedControllers(contentElement, admin, context, deployState, clusterName);
}
- else if (admin.multitenant()) { // system tests: Put on logserver
+ else if (admin.multiTenant()) { // system tests: Put on logserver
if (admin.getClusterControllers() == null) {
// TODO: logserver == null only obtains in unit tests, disallow it
List<HostResource> host = admin.getLogserver() == null ? List.of() : List.of(admin.getLogserver().getHostResource());