feat:add static domain ip map

Author: xiejunqiao

chaos.go

@@ -26,6 +26,8 @@ const (
 	ActionError = "error"
 	// ActionRandom means return random IP for DNS request
 	ActionRandom = "random"
+	// ActionChaos means return chaos IP for DNS request
+	ActionStatic = "static"
 )
 
 // PodInfo saves some information for pod
@@ -39,6 +41,12 @@ type PodInfo struct {
 	LastUpdateTime time.Time
 }
 
+// DomainIP Domain and ip mapping
+type DomainIP struct {
+	Domain string
+	IP     string
+}
+
 // IsOverdue ...
 func (p *PodInfo) IsOverdue() bool {
 	// if the pod's IP is not updated greater than 10 seconds, will treate it as overdue
@@ -55,7 +63,13 @@ func (k Kubernetes) chaosDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
 		return dns.RcodeServerFailure, fmt.Errorf("dns chaos error")
 	}
 
-	// return random IP
+	//return static IP
+	if podInfo.Action == ActionStatic {
+		//return staticIP(ctx, w, r, state, podInfo)
+		//k.chaosMap
+		domainAndIPMap := k.domainAndIPMap[podInfo.Namespace][podInfo.Name]
+		return generateDNSRecords(state, domainAndIPMap, r, w)
+	}
 
 	answers := []dns.RR{}
 	qname := state.Name()
@@ -166,6 +180,9 @@ func (k Kubernetes) needChaos(podInfo *PodInfo, records []dns.RR, name string) b
 	if podInfo.Scope == ScopeAll {
 		return true
 	}
+	if podInfo.Action == ActionStatic && k.domainAndIPMap[podInfo.Namespace][podInfo.Name] != nil {
+		return true
+	}
 
 	rules := podInfo.Selector.Match(name, "")
 	if len(rules) == 0 {
@@ -188,3 +205,34 @@ func (k Kubernetes) getPodFromCluster(namespace, name string) (*api.Pod, error)
 	}
 	return pods.Get(context.Background(), name, meta.GetOptions{})
 }
+
+func generateDNSRecords(state request.Request, domainAndIpMap map[string]string, r *dns.Msg, w dns.ResponseWriter) (int, error) {
+	answers := []dns.RR{}
+	qname := state.Name()
+	if domainAndIpMap == nil {
+		return dns.RcodeServerFailure, nil
+	}
+	ip, ok := domainAndIpMap[qname]
+	if !ok {
+		//如果不存在则
+		return dns.RcodeServerFailure, fmt.Errorf("domain %s not found", qname)
+	}
+	switch state.QType() {
+	case dns.TypeA:
+		ips := []net.IP{net.ParseIP(ip)}
+		log.Debugf("dns.TypeA %v", ips)
+		answers = a(qname, 10, ips)
+	case dns.TypeAAAA:
+		// TODO: return random IP
+		ips := []net.IP{net.ParseIP(ip)}
+		log.Debugf("dns.TypeAAAA %v", ips)
+		answers = aaaa(qname, 10, ips)
+	}
+	m := new(dns.Msg)
+	m.SetReply(r)
+	m.Authoritative = true
+	m.Answer = answers
+
+	w.WriteMsg(m)
+	return dns.RcodeSuccess, nil
+}

go.mod

@@ -9,7 +9,6 @@ require (
 	github.com/miekg/dns v1.1.43
 	github.com/pingcap/tidb-tools v6.3.0+incompatible
 	github.com/prometheus/client_golang v1.11.0
-	golang.org/x/net v0.0.0-20210614182718-04defd469f4e
 	google.golang.org/grpc v1.41.0
 	k8s.io/api v0.22.2
 	k8s.io/apimachinery v0.22.2
@@ -45,6 +44,7 @@ require (
 	github.com/prometheus/common v0.31.1 // indirect
 	github.com/prometheus/procfs v0.6.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
+	golang.org/x/net v0.0.0-20210614182718-04defd469f4e // indirect
 	golang.org/x/oauth2 v0.0.0-20210819190943-2bc19b11175f // indirect
 	golang.org/x/sys v0.0.0-20210917161153-d61c044b1678 // indirect
 	golang.org/x/term v0.0.0-20210220032956-6a3ed077a48d // indirect

grpc_server.go

@@ -44,7 +44,6 @@ func (k Kubernetes) SetDNSChaos(ctx context.Context, req *pb.SetDNSChaosRequest)
 
 	k.Lock()
 	defer k.Unlock()
-
 	k.chaosMap[req.Name] = req
 
 	var scope string
@@ -70,6 +69,15 @@ func (k Kubernetes) SetDNSChaos(ctx context.Context, req *pb.SetDNSChaosRequest)
 			}
 		}
 	}
+	if req.Action == ActionStatic && req.IpDomainMaps != nil {
+		for _, domainIPMap := range req.IpDomainMaps {
+			err := selector.Insert(domainIPMap.Domain, "", true, trieselector.Insert)
+			if err != nil {
+				log.Errorf("fail to build selector %v", err)
+				return nil, err
+			}
+		}
+	}
 
 	for _, pod := range req.Pods {
 		v1Pod, err := k.getPodFromCluster(pod.Namespace, pod.Name)
@@ -100,8 +108,15 @@ func (k Kubernetes) SetDNSChaos(ctx context.Context, req *pb.SetDNSChaosRequest)
 
 		k.podMap[pod.Namespace][pod.Name] = podInfo
 		k.ipPodMap[v1Pod.Status.PodIP] = podInfo
-	}
+		domainIPMap := saveDomainAndIp(req.IpDomainMaps)
+		if domainIPMap != nil {
+			if _, ok := k.domainAndIPMap[pod.Namespace]; !ok {
+				k.domainAndIPMap[pod.Namespace] = make(map[string]map[string]string)
+			}
+			k.domainAndIPMap[pod.Namespace][pod.Name] = domainIPMap
+		}
 
+	}
 	return &pb.DNSChaosResponse{
 		Result: true,
 	}, nil
@@ -125,6 +140,9 @@ func (k Kubernetes) CancelDNSChaos(ctx context.Context, req *pb.CancelDNSChaosRe
 				delete(k.podMap[pod.Namespace], pod.Name)
 				delete(k.ipPodMap, podInfo.IP)
 			}
+			if _, ok1 := k.domainAndIPMap[pod.Namespace][pod.Name]; ok1 {
+				delete(k.domainAndIPMap[pod.Namespace], pod.Name)
+			}
 		}
 	}
 
@@ -136,6 +154,7 @@ func (k Kubernetes) CancelDNSChaos(ctx context.Context, req *pb.CancelDNSChaosRe
 	}
 	for _, namespace := range shouldDeleteNs {
 		delete(k.podMap, namespace)
+		delete(k.domainAndIPMap, namespace)
 	}
 
 	delete(k.chaosMap, req.Name)
@@ -144,3 +163,16 @@ func (k Kubernetes) CancelDNSChaos(ctx context.Context, req *pb.CancelDNSChaosRe
 		Result: true,
 	}, nil
 }
+
+// save domain and ip
+func saveDomainAndIp(domainMapList []*pb.IpDomainMap) map[string]string {
+	if len(domainMapList) == 0 {
+		return nil
+	}
+	domainIPMap := make(map[string]string)
+	for _, domainMap := range domainMapList {
+		key := fmt.Sprintf("%s.", domainMap.Domain)
+		domainIPMap[key] = domainMap.Ip
+	}
+	return domainIPMap
+}

handler.go

@@ -2,7 +2,6 @@ package kubernetes
 
 import (
 	"context"
-
 	"github.com/coredns/coredns/plugin"
 	"github.com/coredns/coredns/request"
 
@@ -22,10 +21,13 @@ func (k Kubernetes) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.M
 
 	records, extra, zone, err := k.getRecords(ctx, state)
 	log.Debugf("records: %v, err: %v", records, err)
-
-	if k.needChaos(chaosPod, records, state.QName()) {
+	if k.needChaos(chaosPod, records, state.QName()) && chaosPod.Action != ActionStatic {
 		return k.chaosDNS(ctx, w, r, state, chaosPod)
 	}
+	if k.needChaos(chaosPod, records, state.QName()) && chaosPod.Action == ActionStatic {
+		log.Infof("need chaos, but action is static")
+		return generateDNSRecords(state, k.domainAndIPMap[chaosPod.Namespace][chaosPod.Name], r, w)
+	}
 
 	if k.IsNameError(err) {
 		if len(zone) == 0 {

kubernetes.go

@@ -5,13 +5,13 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"github.com/chaos-mesh/k8s_dns_chaos/pb"
 	"math/rand"
 	"net"
 	"strings"
 	"sync"
 	"time"
 
-	"github.com/chaos-mesh/k8s_dns_chaos/pb"
 	"github.com/coredns/coredns/plugin"
 	"github.com/coredns/coredns/plugin/etcd/msg"
 	"github.com/coredns/coredns/plugin/kubernetes/object"
@@ -68,6 +68,8 @@ type Kubernetes struct {
 	podMap map[string]map[string]*PodInfo
 
 	ipPodMap map[string]*PodInfo
+
+	domainAndIPMap map[string]map[string]map[string]string
 }
 
 // New returns a initialized Kubernetes. It default interfaceAddrFunc to return 127.0.0.1. All other
@@ -81,6 +83,7 @@ func New(zones []string) *Kubernetes {
 	k.chaosMap = make(map[string]*pb.SetDNSChaosRequest)
 	k.podMap = make(map[string]map[string]*PodInfo)
 	k.ipPodMap = make(map[string]*PodInfo)
+	k.domainAndIPMap = make(map[string]map[string]map[string]string)
 	rand.Seed(time.Now().UnixNano())
 
 	return k