diff options
Diffstat (limited to 'middleware/kubernetes')
| -rw-r--r-- | middleware/kubernetes/autopath.go | 31 | ||||
| -rw-r--r-- | middleware/kubernetes/setup.go | 7 |
2 files changed, 29 insertions, 9 deletions
diff --git a/middleware/kubernetes/autopath.go b/middleware/kubernetes/autopath.go index 3d677e4df..4c5870c6b 100644 --- a/middleware/kubernetes/autopath.go +++ b/middleware/kubernetes/autopath.go @@ -1,11 +1,32 @@ package kubernetes -import "k8s.io/client-go/1.5/pkg/api" +import ( + "fmt" -// TODO(miek): rename and put in autopath.go file. This will be for the -// external middleware autopath to use. Mostly to get the namespace: -//name, path, ok := autopath.SplitSearch(zone, state.QName(), p.Namespace) -func (k *Kubernetes) findPodWithIP(ip string) (p *api.Pod) { + "github.com/coredns/coredns/request" + + "k8s.io/client-go/1.5/pkg/api" +) + +func (k *Kubernetes) AutoPath(state request.Request) ([]string, error) { + ip := state.IP() + + pod := k.PodWithIP(ip) + if pod == nil { + return nil, fmt.Errorf("kubernets: no pod found for %s", ip) + } + + // something something namespace + namespace := pod.Namespace + + search := []string{namespace} // TODO: way more + + search = append(search, "") // sentinal + return search, nil +} + +// PodWithIP return the api.Pod for source IP ip. It return nil if nothing can be found. +func (k *Kubernetes) PodWithIP(ip string) (p *api.Pod) { objList := k.APIConn.PodIndex(ip) for _, o := range objList { p, ok := o.(*api.Pod) diff --git a/middleware/kubernetes/setup.go b/middleware/kubernetes/setup.go index 24c81438d..b28e5df18 100644 --- a/middleware/kubernetes/setup.go +++ b/middleware/kubernetes/setup.go @@ -203,8 +203,7 @@ func kubernetesParse(c *caddy.Controller) (*Kubernetes, error) { } const ( - defaultResyncPeriod = 5 * time.Minute - defautNdots = 0 - defaultResolvConfFile = "/etc/resolv.conf" - defaultOnNXDOMAIN = dns.RcodeSuccess + defaultResyncPeriod = 5 * time.Minute + defautNdots = 0 + defaultOnNXDOMAIN = dns.RcodeSuccess ) |