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

Merge pull request #3862 from johngmyers/epkey-refactor

Browse Source 
Use common EndpointKey type
This commit is contained in:
Kubernetes Prow Robot 2023-09-01 07:54:57 -07:00 committed by GitHub
commit b2de466aa5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
registry/txt.go
View File

@ -34,12 +34,6 @@ const (
providerSpecificForceUpdate = "txt/force-update"
)
type endpointKey struct {
DNSName string
RecordType string
SetIdentifier string
}
// TXTRegistry implements registry interface with ownership implemented via associated TXT records
type TXTRegistry struct {
provider provider.Provider
@ -121,7 +115,7 @@ func (im *TXTRegistry) Records(ctx context.Context) ([]*endpoint.Endpoint, error
endpoints := []*endpoint.Endpoint{}
labelMap := map[endpointKey]endpoint.Labels{}
labelMap := map[endpoint.EndpointKey]endpoint.Labels{}
txtRecordsMap := map[string]struct{}{}
for _, record := range records {
@ -143,7 +137,7 @@ func (im *TXTRegistry) Records(ctx context.Context) ([]*endpoint.Endpoint, error
}
endpointName, recordType := im.mapper.toEndpointName(record.DNSName)
key := endpointKey{
key := endpoint.EndpointKey{
DNSName: endpointName,
RecordType: recordType,
SetIdentifier: record.SetIdentifier,
@ -162,7 +156,7 @@ func (im *TXTRegistry) Records(ctx context.Context) ([]*endpoint.Endpoint, error
dnsNameSplit[0] = im.wildcardReplacement
}
dnsName := strings.Join(dnsNameSplit, ".")
key := endpointKey{
key := endpoint.EndpointKey{
DNSName: dnsName,
RecordType: ep.RecordType,
SetIdentifier: ep.SetIdentifier,