aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/parse.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/kubernetes/parse.go')
-rw-r--r--middleware/kubernetes/parse.go112
1 files changed, 0 insertions, 112 deletions
diff --git a/middleware/kubernetes/parse.go b/middleware/kubernetes/parse.go
deleted file mode 100644
index bf8adfec3..000000000
--- a/middleware/kubernetes/parse.go
+++ /dev/null
@@ -1,112 +0,0 @@
-package kubernetes
-
-import (
- "github.com/coredns/coredns/middleware/pkg/dnsutil"
- "github.com/coredns/coredns/request"
-
- "github.com/miekg/dns"
-)
-
-type recordRequest struct {
- // The named port from the kubernetes DNS spec, this is the service part (think _https) from a well formed
- // SRV record.
- port string
- // The protocol is usually _udp or _tcp (if set), and comes from the protocol part of a well formed
- // SRV record.
- protocol string
- endpoint string
- // The servicename used in Kubernetes.
- service string
- // The namespace used in Kubernetes.
- namespace string
- // A each name can be for a pod or a service, here we track what we've seen, either "pod" or "service".
- podOrSvc string
-}
-
-// parseRequest parses the qname to find all the elements we need for querying k8s. Anything
-// that is not parsed will have the wildcard "*" value (except r.endpoint).
-// Potential underscores are stripped from _port and _protocol.
-func parseRequest(state request.Request) (r recordRequest, err error) {
- // 3 Possible cases:
- // 1. _port._protocol.service.namespace.pod|svc.zone
- // 2. (endpoint): endpoint.service.namespace.pod|svc.zone
- // 3. (service): service.namespace.pod|svc.zone
- //
- // Federations are handled in the federation middleware. And aren't parsed here.
-
- base, _ := dnsutil.TrimZone(state.Name(), state.Zone)
- segs := dns.SplitDomainName(base)
-
- r.port = "*"
- r.protocol = "*"
- r.service = "*"
- r.namespace = "*"
- // r.endpoint is the odd one out, we need to know if it has been set or not. If it is
- // empty we should skip the endpoint check in k.get(). Hence we cannot set if to "*".
-
- // start at the right and fill out recordRequest with the bits we find, so we look for
- // pod|svc.namespace.service and then either
- // * endpoint
- // *_protocol._port
-
- last := len(segs) - 1
- if last < 0 {
- return r, nil
- }
- r.podOrSvc = segs[last]
- if r.podOrSvc != Pod && r.podOrSvc != Svc {
- return r, errInvalidRequest
- }
- last--
- if last < 0 {
- return r, nil
- }
-
- r.namespace = segs[last]
- last--
- if last < 0 {
- return r, nil
- }
-
- r.service = segs[last]
- last--
- if last < 0 {
- return r, nil
- }
-
- // Because of ambiquity we check the labels left: 1: an endpoint. 2: port and protocol.
- // Anything else is a query that is too long to answer and can safely be delegated to return an nxdomain.
- switch last {
-
- case 0: // endpoint only
- r.endpoint = segs[last]
- case 1: // service and port
- r.protocol = stripUnderscore(segs[last])
- r.port = stripUnderscore(segs[last-1])
-
- default: // too long
- return r, errInvalidRequest
- }
-
- return r, nil
-}
-
-// stripUnderscore removes a prefixed underscore from s.
-func stripUnderscore(s string) string {
- if s[0] != '_' {
- return s
- }
- return s[1:]
-}
-
-// String return a string representation of r, it just returns all fields concatenated with dots.
-// This is mostly used in tests.
-func (r recordRequest) String() string {
- s := r.port
- s += "." + r.protocol
- s += "." + r.endpoint
- s += "." + r.service
- s += "." + r.namespace
- s += "." + r.podOrSvc
- return s
-}