summaryrefslogtreecommitdiffstats
path: root/config-provisioning/src/main/java/com/yahoo/config
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-08-18 13:10:18 +0200
committerHarald Musum <musum@verizonmedia.com>2020-08-18 13:10:18 +0200
commit2e41de81b19e137638fa053e82b9a3e960b0c0bd (patch)
tree6762068a34d018a4cd7d6e905ccb2585a190ec59 /config-provisioning/src/main/java/com/yahoo/config
parent8ea8dc943c8efc12fb4f4026457b87dbbe614a93 (diff)
Remove use of flavors from allocated hosts serialization
Diffstat (limited to 'config-provisioning/src/main/java/com/yahoo/config')
-rw-r--r--config-provisioning/src/main/java/com/yahoo/config/provision/HostSpec.java7
-rw-r--r--config-provisioning/src/main/java/com/yahoo/config/provision/serialization/AllocatedHostsSerializer.java31
2 files changed, 13 insertions, 25 deletions
diff --git a/config-provisioning/src/main/java/com/yahoo/config/provision/HostSpec.java b/config-provisioning/src/main/java/com/yahoo/config/provision/HostSpec.java
index fa684ff6046..6bc3809bd54 100644
--- a/config-provisioning/src/main/java/com/yahoo/config/provision/HostSpec.java
+++ b/config-provisioning/src/main/java/com/yahoo/config/provision/HostSpec.java
@@ -45,15 +45,16 @@ public class HostSpec implements Comparable<HostSpec> {
/** Create a host in a hosted system */
public HostSpec(String hostname,
NodeResources realResources,
- NodeResources advertisedResurces,
+ NodeResources advertisedResources,
NodeResources requestedResources,
ClusterMembership membership,
Optional<Version> version,
Optional<NetworkPorts> networkPorts,
Optional<DockerImage> dockerImageRepo) {
- this(hostname, List.of(),
+ this(hostname,
+ List.of(),
realResources,
- advertisedResurces,
+ advertisedResources,
requestedResources,
Optional.of(membership),
version,
diff --git a/config-provisioning/src/main/java/com/yahoo/config/provision/serialization/AllocatedHostsSerializer.java b/config-provisioning/src/main/java/com/yahoo/config/provision/serialization/AllocatedHostsSerializer.java
index 96b189cefe6..6cbd7fba6ff 100644
--- a/config-provisioning/src/main/java/com/yahoo/config/provision/serialization/AllocatedHostsSerializer.java
+++ b/config-provisioning/src/main/java/com/yahoo/config/provision/serialization/AllocatedHostsSerializer.java
@@ -16,7 +16,6 @@ import com.yahoo.slime.SlimeUtils;
import java.io.IOException;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Optional;
@@ -93,7 +92,7 @@ public class AllocatedHostsSerializer {
object.setString(hostSpecDockerImageRepoKey, repo.repository());
});
});
- host.flavor().ifPresent(flavor -> toSlime(flavor, object)); // TODO: Remove this line after June 2020
+ host.flavor().ifPresent(flavor -> toSlime(flavor, object)); // TODO: Remove this line when 7.272 has been released
toSlime(host.realResources(), object.setObject(realResourcesKey));
toSlime(host.advertisedResources(), object.setObject(advertisedResourcesKey));
host.requestedResources().ifPresent(resources -> toSlime(resources, object.setObject(requestedResourcesKey)));
@@ -124,25 +123,25 @@ public class AllocatedHostsSerializer {
resourcesObject.setString(storageTypeKey, storageTypeToString(resources.storageType()));
}
- public static AllocatedHosts fromJson(byte[] json, Optional<NodeFlavors> nodeFlavors) {
- return fromSlime(SlimeUtils.jsonToSlime(json).get(), nodeFlavors);
+ public static AllocatedHosts fromJson(byte[] json) {
+ return fromSlime(SlimeUtils.jsonToSlime(json).get());
}
- public static AllocatedHosts fromSlime(Inspector inspector, Optional<NodeFlavors> nodeFlavors) {
+ public static AllocatedHosts fromSlime(Inspector inspector) {
Inspector array = inspector.field(mappingKey);
Set<HostSpec> hosts = new LinkedHashSet<>();
array.traverse((ArrayTraverser)(i, host) -> {
- hosts.add(hostFromSlime(host.field(hostSpecKey), nodeFlavors));
+ hosts.add(hostFromSlime(host.field(hostSpecKey)));
});
return AllocatedHosts.withHosts(hosts);
}
- private static HostSpec hostFromSlime(Inspector object, Optional<NodeFlavors> nodeFlavors) {
+ private static HostSpec hostFromSlime(Inspector object) {
if (object.field(hostSpecMembershipKey).valid()) { // Hosted
return new HostSpec(object.field(hostSpecHostNameKey).asString(),
- nodeResourcesFromSlime(object.field(realResourcesKey), object, nodeFlavors),
- nodeResourcesFromSlime(object.field(advertisedResourcesKey), object, nodeFlavors),
- optionalNodeResourcesFromSlime(object.field(requestedResourcesKey)), // TODO: Make non-optional after June 2020
+ nodeResourcesFromSlime(object.field(realResourcesKey)),
+ nodeResourcesFromSlime(object.field(advertisedResourcesKey)),
+ nodeResourcesFromSlime(object.field(requestedResourcesKey)),
membershipFromSlime(object),
optionalString(object.field(hostSpecCurrentVespaVersionKey)).map(com.yahoo.component.Version::new),
NetworkPortsSerializer.fromSlime(object.field(hostSpecNetworkPortsKey)),
@@ -178,18 +177,6 @@ public class AllocatedHostsSerializer {
storageTypeFromSlime(resources.field(storageTypeKey)));
}
- private static NodeResources optionalNodeResourcesFromSlime(Inspector resources) {
- if ( ! resources.valid()) return NodeResources.unspecified();
- return nodeResourcesFromSlime(resources);
- }
-
- private static NodeResources nodeResourcesFromSlime(Inspector resources, Inspector parent,
- Optional<NodeFlavors> nodeFlavors) {
- if ( ! resources.valid()) // TODO: Remove the fallback using nodeFlavors after June 2020
- return flavorFromSlime(parent, nodeFlavors).map(f -> f.resources()).orElse(NodeResources.unspecified);
- return nodeResourcesFromSlime(resources);
- }
-
private static NodeResources.DiskSpeed diskSpeedFromSlime(Inspector diskSpeed) {
switch (diskSpeed.asString()) {
case "fast" : return NodeResources.DiskSpeed.fast;