aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/handler.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/kubernetes/handler.go')
-rw-r--r--middleware/kubernetes/handler.go51
1 files changed, 33 insertions, 18 deletions
diff --git a/middleware/kubernetes/handler.go b/middleware/kubernetes/handler.go
index f1a247923..a5916ccf7 100644
--- a/middleware/kubernetes/handler.go
+++ b/middleware/kubernetes/handler.go
@@ -6,7 +6,6 @@ import (
"github.com/coredns/coredns/middleware"
"github.com/coredns/coredns/middleware/pkg/dnsutil"
- "github.com/coredns/coredns/middleware/rewrite"
"github.com/coredns/coredns/request"
"github.com/miekg/dns"
@@ -23,7 +22,6 @@ func (k Kubernetes) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
m := new(dns.Msg)
m.SetReply(r)
m.Authoritative, m.RecursionAvailable, m.Compress = true, true, true
-
// Check that query matches one of the zones served by this middleware,
// otherwise delegate to the next in the pipeline.
zone := middleware.Zones(k.Zones).Matches(state.Name())
@@ -40,10 +38,10 @@ func (k Kubernetes) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
// Set the zone to this specific request.
zone = state.Name()
}
-
records, extra, _, err := k.routeRequest(zone, state)
- if k.AutoPath.Enabled && k.IsNameError(err) {
+ // Check for Autopath search eligibility
+ if k.AutoPath.Enabled && k.IsNameError(err) && (state.QType() == dns.TypeA || state.QType() == dns.TypeAAAA) {
p := k.findPodWithIP(state.IP())
for p != nil {
name, path, ok := splitSearch(zone, state.QName(), p.Namespace)
@@ -53,38 +51,50 @@ func (k Kubernetes) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
if (dns.CountLabel(name) - 1) < k.AutoPath.NDots {
break
}
- // Search "svc.cluster.local" and "cluster.local"
+ origQName := state.QName()
+ // Search "svc.cluster.local." and "cluster.local."
for i := 0; i < 2; i++ {
path = strings.Join(dns.SplitDomainName(path)[1:], ".")
- state = state.NewWithQuestion(strings.Join([]string{name, path}, "."), state.QType())
- records, extra, _, err = k.routeRequest(zone, state)
+ newstate := state.NewWithQuestion(strings.Join([]string{name, path}, "."), state.QType())
+ records, extra, _, err = k.routeRequest(zone, newstate)
if !k.IsNameError(err) {
+ records = append(records, nil)
+ copy(records[1:], records)
+ records[0] = newCNAME(origQName, records[0].Header().Name, records[0].Header().Ttl)
break
}
}
if !k.IsNameError(err) {
break
}
- // Fallthrough with the host search path (if set)
- wr := rewrite.NewResponseReverter(w, r)
+ // Try host search path (if set) in the next middleware
+ apw := NewAutoPathWriter(w, r)
for _, hostsearch := range k.AutoPath.HostSearchPath {
- r = state.NewWithQuestion(strings.Join([]string{name, hostsearch}, "."), state.QType()).Req
- rcode, nextErr := middleware.NextOrFailure(k.Name(), k.Next, ctx, wr, r)
- if rcode == dns.RcodeSuccess {
+ newstate := state.NewWithQuestion(strings.Join([]string{name, hostsearch}, "."), state.QType())
+ rcode, nextErr := middleware.NextOrFailure(k.Name(), k.Next, ctx, apw, newstate.Req)
+ if apw.Sent {
return rcode, nextErr
}
}
// Search . in this middleware
- state = state.NewWithQuestion(strings.Join([]string{name, "."}, ""), state.QType())
- records, extra, _, err = k.routeRequest(zone, state)
+ newstate := state.NewWithQuestion(strings.Join([]string{name, "."}, ""), state.QType())
+ records, extra, _, err = k.routeRequest(zone, newstate)
if !k.IsNameError(err) {
+ records = append(records, nil)
+ copy(records[1:], records)
+ records[0] = newCNAME(origQName, records[0].Header().Name, records[0].Header().Ttl)
break
}
// Search . in the next middleware
- r = state.Req
- rcode, nextErr := middleware.NextOrFailure(k.Name(), k.Next, ctx, wr, r)
- if rcode == dns.RcodeNameError {
- rcode = k.AutoPath.OnNXDOMAIN
+ apw.Rcode = k.AutoPath.OnNXDOMAIN
+ newstate = state.NewWithQuestion(strings.Join([]string{name, "."}, ""), state.QType())
+ r = newstate.Req
+ rcode, nextErr := middleware.NextOrFailure(k.Name(), k.Next, ctx, apw, r)
+ if !apw.Sent && nextErr == nil {
+ r = dnsutil.Dedup(r)
+ state.SizeAndDo(r)
+ r, _ = state.Scrub(r)
+ apw.ForceWriteMsg(r)
}
return rcode, nextErr
}
@@ -115,6 +125,11 @@ func (k Kubernetes) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
return dns.RcodeSuccess, nil
}
+func newCNAME(name string, target string, ttl uint32) *dns.CNAME {
+ // TODO factor this out and put in dnsutil
+ return &dns.CNAME{Hdr: dns.RR_Header{Name: name, Rrtype: dns.TypeCNAME, Class: dns.ClassINET, Ttl: ttl}, Target: dns.Fqdn(target)}
+}
+
func (k *Kubernetes) routeRequest(zone string, state request.Request) (records []dns.RR, extra []dns.RR, debug []dns.RR, err error) {
switch state.Type() {
case "A":
te-setup-hook'>fryuni/test-route-setup-hook Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/examples/framework-svelte/src (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2024-02-27Improve the message of `MiddlewareCantBeLoaded` for clarity (#10239)Gravatar Ming-jun Lu 2-1/+6
2024-02-26[ci] formatGravatar Martin Trapp 1-1/+3
2024-02-26Warn when view transitions run on a prefer-reduced-motion device (#10222)Gravatar Martin Trapp 2-0/+8
2024-02-26[ci] release (#10218)astro@4.4.5@astrojs/vercel@7.3.4@astrojs/svelte@5.1.0@astrojs/db@0.4.1Gravatar Houston (Bot) 46-114/+100
2024-02-26fix: better assetsInlineLimit runtime type checking (#10154)Gravatar James Ross 2-9/+13
2024-02-26fix: correct remote url (#10223)Gravatar Ben Holmes 2-2/+8
2024-02-26fix(toolbar): Make it so every built-in app can be closed by outside clicks (...Gravatar Erika 8-51/+63
2024-02-26Fix an issue where Vercel adapter may create functions for prerendered routes...Gravatar Ming-jun Lu 4-2/+26
2024-02-26[ci] formatGravatar Matthew Phillips 1-1/+1
2024-02-26Fix hydration scripts missing from dynamic slot usage (#10219)Gravatar Matthew Phillips 6-1/+69
2024-02-26[ci] formatGravatar Matthew Phillips 1-5/+5
2024-02-26Prevent errors in rendering from crashing server (#10221)Gravatar Matthew Phillips 7-14/+78
2024-02-26fix: svelte 5 mount/hydrate api change. (#10224)Gravatar 前端子鱼 3-5/+12
2024-02-24[ci] formatGravatar Arsh 1-9/+30
2024-02-24prevent warning: `Astro.request.headers` is not available in "static" output ...Gravatar Arsh 2-27/+30
2024-02-23Improved error logging from config (#10207)Gravatar Ben Holmes 4-36/+67
2024-02-23[ci] formatGravatar Arsh 3-3/+3
2024-02-23fix(dev): remove params for prerendered pages (#10199)Gravatar Arsh 9-13/+78
2024-02-23[ci] release (#10213)astro@4.4.4@astrojs/vercel@7.3.3@astrojs/node@8.2.1@astrojs/db@0.4.0Gravatar Houston (Bot) 41-177/+95
2024-02-23Fixes edge middleware calling nested routes (#10215)Gravatar Matthew Phillips 2-1/+6
2024-02-23Adds an error message for non-string transition:name values (#10205)Gravatar Martin Trapp 2-0/+8
2024-02-23[ci] formatGravatar Furkan Erdem 1-1/+1
2024-02-23Fix(node): Custom headers are not present in responses from standalone Node s...Gravatar Furkan Erdem 8-0/+163