@@ -263,7 +263,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
263
263
continue
264
264
}
265
265
266
- findMsgZone (ep , m , & r )
266
+ zone := findMsgZone (ep , m , r )
267
+ r .krb5Realm = strings .ToUpper (zone )
268
+ m .SetUpdate (zone )
267
269
268
270
r .AddRecord (m , ep )
269
271
}
@@ -290,7 +292,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
290
292
continue
291
293
}
292
294
293
- findMsgZone (ep , m , & r )
295
+ zone := findMsgZone (ep , m , r )
296
+ r .krb5Realm = strings .ToUpper (zone )
297
+ m .SetUpdate (zone )
294
298
295
299
r .UpdateRecord (m , changes .UpdateOld [i ], ep )
296
300
}
@@ -317,7 +321,9 @@ func (r rfc2136Provider) ApplyChanges(ctx context.Context, changes *plan.Changes
317
321
continue
318
322
}
319
323
320
- findMsgZone (ep , m , & r )
324
+ zone := findMsgZone (ep , m , r )
325
+ r .krb5Realm = strings .ToUpper (zone )
326
+ m .SetUpdate (zone )
321
327
322
328
r .RemoveRecord (m , ep )
323
329
}
@@ -451,17 +457,13 @@ func chunkBy(slice []*endpoint.Endpoint, chunkSize int) [][]*endpoint.Endpoint {
451
457
return chunks
452
458
}
453
459
454
- func findMsgZone (ep * endpoint.Endpoint , m * dns.Msg , r * rfc2136Provider ) {
460
+ func findMsgZone (ep * endpoint.Endpoint , m * dns.Msg , r rfc2136Provider ) string {
455
461
for _ , zone := range r .zoneNames {
456
462
if strings .HasSuffix (ep .DNSName , zone ) {
457
- r .krb5Realm = strings .ToUpper (dns .Fqdn (zone ))
458
- m .SetUpdate (dns .Fqdn (zone ))
459
-
460
- return
463
+ return dns .Fqdn (zone )
461
464
}
462
465
}
463
466
464
467
log .Warnf ("No available zone found for %s, set it to 'root'" , ep .DNSName )
465
- r .krb5Realm = dns .Fqdn ("." )
466
- m .SetUpdate (dns .Fqdn ("." ))
468
+ return dns .Fqdn ("." )
467
469
}
0 commit comments