diff options
author | Martin Polden <mpolden@mpolden.no> | 2021-11-08 15:06:05 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2021-11-09 14:20:27 +0100 |
commit | 08a1bc42a544f5d6193850f95137b9f21d41c16a (patch) | |
tree | eb2f76658641f5f20c603e637e045767da14bc48 /controller-server | |
parent | f610c39bdec3aae45b323682b3c62687ccaa0a79 (diff) |
Add scope to container endpoint
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java index 6afee557029..ffaa0f2cb53 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/RoutingController.java @@ -277,6 +277,7 @@ public class RoutingController { // Include rotation ID as a valid name of this container endpoint (required by global routing health checks) names.add(assignedRotation.rotationId().asString()); containerEndpoints.add(new ContainerEndpoint(assignedRotation.clusterId().value(), + asString(Endpoint.Scope.global), names)); } // Add endpoints not backed by a rotation (i.e. other routing methods so that the config server always knows @@ -287,6 +288,7 @@ public class RoutingController { .groupingBy(Endpoint::cluster) .forEach((clusterId, clusterEndpoints) -> { containerEndpoints.add(new ContainerEndpoint(clusterId.value(), + asString(Endpoint.Scope.global), clusterEndpoints.mapToList(Endpoint::dnsName))); }); return Collections.unmodifiableSet(containerEndpoints); @@ -411,5 +413,14 @@ public class RoutingController { return endpoints; } + private static String asString(Endpoint.Scope scope) { + switch (scope) { + case application: return "application"; + case global: return "global"; + case weighted: return "weighted"; + case zone: return "zone"; + } + throw new IllegalArgumentException("Unknown scope " + scope); + } } |