mirrors/external-dns
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/external-dns.git synced 2026-05-05 22:56:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

RFC2136: return string from findMsgZone

Browse Source
This commit is contained in:
s.kharlamov 2023-10-17 23:06:47 +00:00
parent 714078dc95
commit 7fb529965d
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
provider/rfc2136/rfc2136.go
View File

@ -263,7 +263,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
continue
}
findMsgZone(ep, m, &r)
zone := findMsgZone(ep, m, r)
r.krb5Realm = strings.ToUpper(zone)
m.SetUpdate(zone)
r.AddRecord(m, ep)
}
@ -290,7 +292,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
continue
}
findMsgZone(ep, m, &r)
zone := findMsgZone(ep, m, r)
r.krb5Realm = strings.ToUpper(zone)
m.SetUpdate(zone)
r.UpdateRecord(m, changes.UpdateOld[i], ep)
}
@ -317,7 +321,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
continue
}
findMsgZone(ep, m, &r)
zone := findMsgZone(ep, m, r)
r.krb5Realm = strings.ToUpper(zone)
m.SetUpdate(zone)
r.RemoveRecord(m, ep)
}
@ -451,17 +457,13 @@ func chunkBy(slice []*endpoint.Endpoint, chunkSize int) [][]*endpoint.Endpoint {
return chunks
}
func findMsgZone(ep *endpoint.Endpoint, m *dns.Msg, r *rfc2136Provider) {
func findMsgZone(ep *endpoint.Endpoint, m *dns.Msg, r rfc2136Provider) string {
for _, zone := range r.zoneNames {
if strings.HasSuffix(ep.DNSName, zone) {
r.krb5Realm = strings.ToUpper(dns.Fqdn(zone))
m.SetUpdate(dns.Fqdn(zone))
return
return dns.Fqdn(zone)
}
}
log.Warnf("No available zone found for %s, set it to 'root'", ep.DNSName)
r.krb5Realm = dns.Fqdn(".")
m.SetUpdate(dns.Fqdn("."))
return dns.Fqdn(".")
}