diff options
Diffstat (limited to 'node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java')
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java | 63 |
1 files changed, 29 insertions, 34 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java index 94805e37105..dc1fb5639c2 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/component/Environment.java @@ -41,6 +41,7 @@ public class Environment { private static final String ENVIRONMENT = "ENVIRONMENT"; private static final String REGION = "REGION"; private static final String SYSTEM = "SYSTEM"; + private static final String CLOUD = "CLOUD"; private static final String LOGSTASH_NODES = "LOGSTASH_NODES"; private static final String COREDUMP_FEED_ENDPOINT = "COREDUMP_FEED_ENDPOINT"; @@ -59,6 +60,7 @@ public class Environment { private final Optional<AthenzIdentity> athenzIdentity; private final NodeType nodeType; private final String defaultFlavor; + private final String cloud; static { filenameFormatter.setTimeZone(TimeZone.getTimeZone("UTC")); @@ -69,36 +71,17 @@ public class Environment { getEnvironmentVariable(ENVIRONMENT), getEnvironmentVariable(REGION), getEnvironmentVariable(SYSTEM), - + Defaults.getDefaults().vespaHostname(), + new InetAddressResolver(), new PathResolver(), + getLogstashNodesFromEnvironment(), Optional.of(getEnvironmentVariable(COREDUMP_FEED_ENDPOINT)), NodeType.host, - "d-2-8-50"); - } - - public Environment(ConfigServerConfig configServerConfig, - String hostedEnvironment, - String hostedRegion, - String hostedSystem, - PathResolver pathResolver, - Optional<String> coreDumpFeedEndpoint, - NodeType nodeType, - String defaultFlavor) { - this(configServerConfig, - hostedEnvironment, - hostedRegion, - hostedSystem, - Defaults.getDefaults().vespaHostname(), - new InetAddressResolver(), - pathResolver, - getLogstashNodesFromEnvironment(), - coreDumpFeedEndpoint, - nodeType, - defaultFlavor - ); + "d-2-8-50", + getEnvironmentVariable(CLOUD)); } - public Environment(ConfigServerConfig configServerConfig, + private Environment(ConfigServerConfig configServerConfig, String environment, String region, String system, @@ -108,7 +91,15 @@ public class Environment { List<String> logstashNodes, Optional<String> coreDumpFeedEndpoint, NodeType nodeType, - String defaultFlavor) { + String defaultFlavor, + String cloud) { + Objects.requireNonNull(configServerConfig, "configServerConfig cannot be null"); + Objects.requireNonNull(environment, "environment cannot be null"); + Objects.requireNonNull(region, "region cannot be null"); + Objects.requireNonNull(system, "system cannot be null"); + Objects.requireNonNull(defaultFlavor, "default flavor cannot be null"); + Objects.requireNonNull(cloud, "cloud cannot be null"); + this.configServerHostNames = configServerConfig.hosts(); this.configServerURIs = createConfigServerUris( configServerConfig.scheme(), @@ -136,6 +127,7 @@ public class Environment { this.coredumpFeedEndpoint = coreDumpFeedEndpoint; this.nodeType = nodeType; this.defaultFlavor = defaultFlavor; + this.cloud = cloud; } public List<String> getConfigServerHostNames() { return configServerHostNames; } @@ -168,7 +160,7 @@ public class Environment { return getEnvironment() + "." + getRegion(); } - public static List<URI> createConfigServerUris(String scheme, List<String> configServerHosts, int port) { + private static List<URI> createConfigServerUris(String scheme, List<String> configServerHosts, int port) { return configServerHosts.stream() .map(hostname -> URI.create(scheme + "://" + hostname + ":" + port)) .collect(Collectors.toList()); @@ -278,6 +270,8 @@ public class Environment { public String getDefaultFlavor() { return defaultFlavor; } + public String getCloud() { return cloud; } + public static class Builder { private ConfigServerConfig configServerConfig; private String environment; @@ -290,6 +284,7 @@ public class Environment { private Optional<String> coredumpFeedEndpoint = Optional.empty(); private NodeType nodeType = NodeType.tenant; private String defaultFlavor; + private String cloud; public Builder configServerConfig(ConfigServerConfig configServerConfig) { this.configServerConfig = configServerConfig; @@ -346,13 +341,12 @@ public class Environment { return this; } - public Environment build() { - Objects.requireNonNull(configServerConfig, "configServerConfig cannot be null"); - Objects.requireNonNull(environment, "environment cannot be null"); - Objects.requireNonNull(region, "region cannot be null"); - Objects.requireNonNull(system, "system cannot be null"); - Objects.requireNonNull(defaultFlavor, "default flavor cannot be null"); + public Builder cloud(String cloud) { + this.cloud = cloud; + return this; + } + public Environment build() { return new Environment(configServerConfig, environment, region, @@ -363,7 +357,8 @@ public class Environment { logstashNodes, coredumpFeedEndpoint, nodeType, - defaultFlavor); + defaultFlavor, + cloud); } } } |