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
-}
ream-file-bun.js?h=fix-websocket-upgrade&follow=1'>logtreecommitdiff
path: root/bench/stream-file-upload-client/stream-file-bun.js (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2023-10-17Remove ancient changelogGravatar Ashcon Partovi 1-11/+0
2023-10-17docs: fix ws.publish (#6558)Gravatar Aral Roca Gomez 1-1/+1
2023-10-17perf(bun-types): remove needless some call (#6550)Gravatar Mikhail 1-1/+1
2023-10-16fix(runtime): make some things more stable (partial jsc debug build) (#5881)Gravatar dave caruso 116-1446/+1830
2023-10-16fix(runtime): improve IPC reliability + organization pass on that code (#6475)Gravatar dave caruso 15-98/+266
2023-10-16Simplify getting Set of extentions (#4975)Gravatar Mikhail 1-3/+3
2023-10-16Fix formattingGravatar Ashcon Partovi 1-3/+1
2023-10-16fix(test): when tests run with --only the nested describe blocks `.on… (#5616)Gravatar Igor Shapiro 2-13/+45
2023-10-16perf(node:events): optimize `emit(...)` function (#5485)Gravatar Yannik Schröder 3-11/+132
2023-10-16fix: don't remove content-encoding header from header table (#5743)Gravatar Liz 2-2/+25
2023-10-16fix(sqlite) Insert .all() does not return an array #5872 (#5946)Gravatar Hugo Galan 2-7/+11
2023-10-16Fix formattingGravatar Ashcon Partovi 2-5/+4
2023-10-16Fix `Response.statusText` (#6151)Gravatar Chris Toshok 10-238/+269
2023-10-16fix-subprocess-argument-missing (#6407)Gravatar Nicolae-Rares Ailincai 4-2/+40
2023-10-16Add type parameter to `expect` (#6128)Gravatar Voldemat 1-3/+3
2023-10-16fix(node:worker_threads): ensure threadId property is exposed on worker_threa...Gravatar Jérôme Benoit 6-15/+75
2023-10-16Fix use before define bug in sqliteGravatar Ashcon Partovi 2-5/+5
2023-10-16fix(jest): fix toStrictEqual on same URLs (#6528)Gravatar João Alisson 2-13/+16
2023-10-16Fix `toHaveBeenCalled` having wrong error signatureGravatar Ashcon Partovi 1-2/+2
2023-10-16Fix formattingGravatar Ashcon Partovi 1-2/+1
2023-10-16Add `reusePort` to `Bun.serve` typesGravatar Ashcon Partovi 1-0/+9
2023-10-16Fix `request.url` having incorrect portGravatar Ashcon Partovi 4-1/+92
2023-10-16Remove uWebSockets header from Bun.serve responsesGravatar Ashcon Partovi 1-6/+6
2023-10-16Rename some testsGravatar Ashcon Partovi 3-0/+0
2023-10-16Fix #6467Gravatar Ashcon Partovi 2-3/+10
2023-10-16Update InternalModuleRegistryConstants.hGravatar Dylan Conway 1-3/+3
2023-10-16Development -> Contributing (#6538)Gravatar Colin McDonnell 2-1/+1
2023-10-14fix(net/tls) fix pg hang on end + hanging on query (#6487)Gravatar Ciro Spaciari 3-8/+36
2023-10-13fix installing dependencies that match workspace versions (#6494)Gravatar Dylan Conway 4-2/+64
2023-10-13fix lockfile struct padding (#6495)Gravatar Dylan Conway 3-3/+18