summaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java
diff options
context:
space:
mode:
Diffstat (limited to 'config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java16
1 files changed, 11 insertions, 5 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java b/config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java
index 2baf8f053c9..9804cb0b10d 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/container/xml/ContainerModelBuilder.java
@@ -627,14 +627,12 @@ public class ContainerModelBuilder extends ConfigModelBuilder<ContainerModel> {
private void addCloudTokenSupport(DeployState state, ApplicationContainerCluster cluster) {
var server = cluster.getHttp().getHttpServer().get();
- Set<String> tokenEndpoints = state.getEndpoints().stream()
- .filter(endpoint -> endpoint.authMethod() == ApplicationClusterEndpoint.AuthMethod.token)
+ Set<String> tokenEndpoints = tokenEndpoints(state).stream()
.map(ContainerEndpoint::names)
.flatMap(Collection::stream)
.collect(Collectors.toSet());
boolean enableTokenSupport = state.isHosted() && state.zone().system().isPublic()
- && state.featureFlags().enableDataplaneProxy()
&& cluster.getClients().stream().anyMatch(c -> !c.tokens().isEmpty())
&& ! tokenEndpoints.isEmpty();
if (!enableTokenSupport) return;
@@ -1451,11 +1449,19 @@ public class ContainerModelBuilder extends ConfigModelBuilder<ContainerModel> {
}
private static int getMtlsDataplanePort(DeployState ds) {
- return ds.featureFlags().enableDataplaneProxy() ? 8443 : 4443;
+ boolean enableDataplaneProxy = ! tokenEndpoints(ds).isEmpty();
+ return enableDataplaneProxy ? 8443 : 4443;
}
private static OptionalInt getTokenDataplanePort(DeployState ds) {
- return ds.featureFlags().enableDataplaneProxy() ? OptionalInt.of(8444) : OptionalInt.empty();
+ boolean enableDataplaneProxy = ! tokenEndpoints(ds).isEmpty();
+ return enableDataplaneProxy ? OptionalInt.of(8444) : OptionalInt.empty();
+ }
+
+ private static Set<ContainerEndpoint> tokenEndpoints(DeployState deployState) {
+ return deployState.getEndpoints().stream()
+ .filter(endpoint -> endpoint.authMethod() == ApplicationClusterEndpoint.AuthMethod.token)
+ .collect(Collectors.toSet());
}
}