aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/lookup.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/kubernetes/lookup.go')
-rw-r--r--middleware/kubernetes/lookup.go18
1 files changed, 9 insertions, 9 deletions
diff --git a/middleware/kubernetes/lookup.go b/middleware/kubernetes/lookup.go
index 1efec7475..b490d6a4b 100644
--- a/middleware/kubernetes/lookup.go
+++ b/middleware/kubernetes/lookup.go
@@ -17,7 +17,7 @@ func (k Kubernetes) records(state middleware.State, exact bool) ([]msg.Service,
if err != nil {
return nil, err
}
- // TODO: Do we want to support the SkyDNS (hacky) Group feature?
+ // TODO: Do we want to support the SkyDNS (hacky) Group feature?
services = msg.Group(services)
return services, nil
}
@@ -141,7 +141,7 @@ func (k Kubernetes) AAAA(zone string, state middleware.State, previousRecords []
return records, nil
}
-// SRV returns SRV records from etcd.
+// SRV returns SRV records from kubernetes.
// If the Target is not a name but an IP address, a name is created on the fly.
func (k Kubernetes) SRV(zone string, state middleware.State) (records []dns.RR, extra []dns.RR, err error) {
services, err := k.records(state, false)
@@ -208,13 +208,13 @@ func (k Kubernetes) SRV(zone string, state middleware.State) (records []dns.RR,
}
// k.AAA(zone, state1, nil) as well...?
case ip.To4() != nil:
- serv.Host = k.Domain(serv.Key)
+ serv.Host = serv.Key
srv := serv.NewSRV(state.QName(), weight)
records = append(records, srv)
extra = append(extra, serv.NewA(srv.Target, ip.To4()))
case ip.To4() == nil:
- serv.Host = k.Domain(serv.Key)
+ serv.Host = serv.Key
srv := serv.NewSRV(state.QName(), weight)
records = append(records, srv)
@@ -226,17 +226,17 @@ func (k Kubernetes) SRV(zone string, state middleware.State) (records []dns.RR,
// Returning MX records from kubernetes not implemented.
func (k Kubernetes) MX(zone string, state middleware.State) (records []dns.RR, extra []dns.RR, err error) {
- return nil, nil, err
+ return nil, nil, err
}
// Returning CNAME records from kubernetes not implemented.
func (k Kubernetes) CNAME(zone string, state middleware.State) (records []dns.RR, err error) {
- return nil, err
+ return nil, err
}
// Returning TXT records from kubernetes not implemented.
func (k Kubernetes) TXT(zone string, state middleware.State) (records []dns.RR, err error) {
- return nil, err
+ return nil, err
}
func (k Kubernetes) NS(zone string, state middleware.State) (records, extra []dns.RR, err error) {
@@ -259,11 +259,11 @@ func (k Kubernetes) NS(zone string, state middleware.State) (records, extra []dn
case ip == nil:
return nil, nil, fmt.Errorf("NS record must be an IP address: %s", serv.Host)
case ip.To4() != nil:
- serv.Host = k.Domain(serv.Key)
+ serv.Host = serv.Key
records = append(records, serv.NewNS(state.QName()))
extra = append(extra, serv.NewA(serv.Host, ip.To4()))
case ip.To4() == nil:
- serv.Host = k.Domain(serv.Key)
+ serv.Host = serv.Key
records = append(records, serv.NewNS(state.QName()))
extra = append(extra, serv.NewAAAA(serv.Host, ip.To16()))
}