aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/kubernetes.go
diff options
context:
space:
mode:
authorGravatar Mia Boulay <mia.boulay@linux.com> 2017-07-01 18:19:57 -0400
committerGravatar Miek Gieben <miek@miek.nl> 2017-07-01 15:19:57 -0700
commitade76030212d9a8c46cb06b9c930554d8a927ef7 (patch)
tree785098747f95106a592209724892014e1f78f156 /middleware/kubernetes/kubernetes.go
parent7fada97ee384aad27f7c7796038eef2684a3642c (diff)
downloadcoredns-ade76030212d9a8c46cb06b9c930554d8a927ef7.tar.gz
coredns-ade76030212d9a8c46cb06b9c930554d8a927ef7.tar.zst
coredns-ade76030212d9a8c46cb06b9c930554d8a927ef7.zip
middleware/backend: add Records() to ServiceBackend interface (#770)
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
-rw-r--r--middleware/kubernetes/kubernetes.go13
1 files changed, 9 insertions, 4 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go
index a1e6bdb73..13f92adca 100644
--- a/middleware/kubernetes/kubernetes.go
+++ b/middleware/kubernetes/kubernetes.go
@@ -124,10 +124,10 @@ func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware.
svcs = append(svcs, k.defaultNSMsg(r))
return svcs, nil, nil
}
- s, e := k.Records(r)
+ s, e := k.Entries(r)
return s, nil, e // Haven't implemented debug queries yet.
case "SRV":
- s, e := k.Records(r)
+ s, e := k.Entries(r)
// SRV for external services is not yet implemented, so remove those records
noext := []msg.Service{}
for _, svc := range s {
@@ -347,10 +347,15 @@ func (k *Kubernetes) parseRequest(lowerCasedName string, qtype uint16) (r record
}
-// Records looks up services in kubernetes. If exact is true, it will lookup
+// Records not implemented, see Entries().
+func (k *Kubernetes) Records(name string, exact bool) ([]msg.Service, error) {
+ return nil, fmt.Errorf("NOOP")
+}
+
+// Entries looks up services in kubernetes. If exact is true, it will lookup
// just this name. This is used when find matches when completing SRV lookups
// for instance.
-func (k *Kubernetes) Records(r recordRequest) ([]msg.Service, error) {
+func (k *Kubernetes) Entries(r recordRequest) ([]msg.Service, error) {
// Abort if the namespace does not contain a wildcard, and namespace is not published per CoreFile
// Case where namespace contains a wildcard is handled in Get(...) method.