diff options
author | Torbjørn Smørgrav <smorgrav@users.noreply.github.com> | 2018-10-04 14:00:00 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-10-04 14:00:00 +0200 |
commit | 963d16440f7534e39cbe36be695c272a95b7e3fb (patch) | |
tree | 36af8a565ba0d6bde83f5c7b67e95e51bf288f11 /controller-server/src | |
parent | 46f4c5c7c91550c0e9561ca61dc044f01d56c12f (diff) | |
parent | 502a44bb90ced322931e606c920e0e2ae992ef4f (diff) |
Merge pull request #7197 from vespa-engine/smorgrav/expand_nameservice
Add method to look up multiple records by name and apply this
Diffstat (limited to 'controller-server/src')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java index c2dbc8bdc59..79bc72f950d 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java @@ -482,16 +482,19 @@ public class ApplicationController { /** Register a DNS name for rotation */ private void registerRotationInDns(Rotation rotation, String dnsName) { try { - Optional<Record> record = nameService.findRecord(Record.Type.CNAME, RecordName.from(dnsName)); + RecordData rotationName = RecordData.fqdn(rotation.name()); - if (record.isPresent()) { + List<Record> records = nameService.findRecords(Record.Type.CNAME, RecordName.from(dnsName)); + records.forEach(record -> { // Ensure that the existing record points to the correct rotation - if ( ! record.get().data().equals(rotationName)) { - nameService.updateRecord(record.get().id(), rotationName); - log.info("Updated mapping for record ID " + record.get().id().asString() + ": '" + dnsName - + "' -> '" + rotation.name() + "'"); + if ( ! record.data().equals(rotationName)) { + nameService.updateRecord(record.id(), rotationName); + log.info("Updated mapping for record ID " + record.id().asString() + ": '" + dnsName + + "' -> '" + rotation.name() + "'"); } - } else { + }); + + if (records.isEmpty()) { RecordId id = nameService.createCname(RecordName.from(dnsName), rotationName); log.info("Registered mapping with record ID " + id.asString() + ": '" + dnsName + "' -> '" + rotation.name() + "'"); |