blob: 4c5870c6b30af26da8e9ecc7db9f326af3d3a0a3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
package kubernetes
import (
"fmt"
"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)
if !ok {
return nil
}
return p
}
return nil
}
|
