diff options
author | Martin Polden <mpolden@mpolden.no> | 2019-04-30 20:08:59 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2019-04-30 20:08:59 +0200 |
commit | ea123e8d0e2bae4250126cc21659c8b115248367 (patch) | |
tree | 69b69cfcce5319959b01d186b10c2979ef3d329f /controller-server | |
parent | dd219ffd3416e1a752c50d92dfb8461e4689510a (diff) |
Improve names
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPolicyMaintainer.java | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPolicyMaintainer.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPolicyMaintainer.java index 9c4fa8115db..11703ed4845 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPolicyMaintainer.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/RoutingPolicyMaintainer.java @@ -34,7 +34,7 @@ import java.util.logging.Logger; import java.util.stream.Collectors; /** - * Maintains DNS records as defined by routing policies for all exclusive load balancers in this system. + * Maintains routing policies and their DNS records for all exclusive load balancers in this system. * * @author mortent * @author mpolden @@ -64,10 +64,10 @@ public class RoutingPolicyMaintainer extends Maintainer { @Override protected void maintain() { Map<DeploymentId, List<LoadBalancer>> loadBalancers = findLoadBalancers(); - removeObsoleteAliases(loadBalancers); - registerCnames(loadBalancers); - removeObsoleteCnames(loadBalancers); - registerAliases(); + removeObsoleteEndpointsFromDns(loadBalancers); + storePolicies(loadBalancers); + removeObsoletePolicies(loadBalancers); + registerEndpointsInDns(); } /** Find all exclusive load balancers in this system, grouped by deployment */ @@ -89,8 +89,8 @@ public class RoutingPolicyMaintainer extends Maintainer { return Collections.unmodifiableMap(result); } - /** Create aliases (global rotations) for all current routing policies */ - private void registerAliases() { + /** Create global endpoints for all current routing policies */ + private void registerEndpointsInDns() { try (Lock lock = db.lockRoutingPolicies()) { Map<RoutingId, List<RoutingPolicy>> routingTable = routingTableFrom(db.readRoutingPolicies()); @@ -115,8 +115,8 @@ public class RoutingPolicyMaintainer extends Maintainer { } } - /** Create CNAME records for each individual load balancers */ - private void registerCnames(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { + /** Store routing policies for all load balancers */ + private void storePolicies(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { for (Map.Entry<DeploymentId, List<LoadBalancer>> entry : loadBalancers.entrySet()) { ApplicationId application = entry.getKey().applicationId(); ZoneId zone = entry.getKey().zoneId(); @@ -124,7 +124,7 @@ public class RoutingPolicyMaintainer extends Maintainer { Set<RoutingPolicy> policies = new LinkedHashSet<>(db.readRoutingPolicies(application)); for (LoadBalancer loadBalancer : entry.getValue()) { try { - RoutingPolicy policy = registerCname(application, zone, loadBalancer); + RoutingPolicy policy = storePolicy(application, zone, loadBalancer); if (!policies.add(policy)) { policies.remove(policy); policies.add(policy); @@ -140,8 +140,8 @@ public class RoutingPolicyMaintainer extends Maintainer { } } - /** Register DNS alias for given load balancer */ - private RoutingPolicy registerCname(ApplicationId application, ZoneId zone, LoadBalancer loadBalancer) { + /** Store policy for given load balancer and request a CNAME for it */ + private RoutingPolicy storePolicy(ApplicationId application, ZoneId zone, LoadBalancer loadBalancer) { RoutingPolicy routingPolicy = new RoutingPolicy(application, loadBalancer.cluster(), zone, loadBalancer.hostname(), loadBalancer.dnsZone(), loadBalancer.rotations()); @@ -151,8 +151,8 @@ public class RoutingPolicyMaintainer extends Maintainer { return routingPolicy; } - /** Remove all DNS records that point to non-existing load balancers */ - private void removeObsoleteCnames(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { + /** Remove obsolete policies and their CNAME records */ + private void removeObsoletePolicies(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { try (Lock lock = db.lockRoutingPolicies()) { Set<RoutingPolicy> removalCandidates = db.readRoutingPolicies().values().stream() .flatMap(Collection::stream) @@ -171,8 +171,8 @@ public class RoutingPolicyMaintainer extends Maintainer { } } - /** Remove global rotations that are not referenced by given load balancers */ - private void removeObsoleteAliases(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { + /** Remove DNS for global endpoints not referenced by given load balancers */ + private void removeObsoleteEndpointsFromDns(Map<DeploymentId, List<LoadBalancer>> loadBalancers) { try (Lock lock = db.lockRoutingPolicies()) { Set<RoutingId> removalCandidates = routingTableFrom(db.readRoutingPolicies()).keySet(); Set<RoutingId> activeRoutingIds = routingIdsFrom(loadBalancers); @@ -197,7 +197,7 @@ public class RoutingPolicyMaintainer extends Maintainer { return Collections.unmodifiableSet(routingIds); } - /** Compute a routing table from given policies. */ + /** Compute a routing table from given policies */ private static Map<RoutingId, List<RoutingPolicy>> routingTableFrom(Map<ApplicationId, Set<RoutingPolicy>> routingPolicies) { var flattenedPolicies = routingPolicies.values().stream().flatMap(Collection::stream).collect(Collectors.toSet()); var routingTable = new LinkedHashMap<RoutingId, List<RoutingPolicy>>(); |