diff options
Diffstat (limited to 'plugin/kubernetes/federation.go')
| -rw-r--r-- | plugin/kubernetes/federation.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/plugin/kubernetes/federation.go b/plugin/kubernetes/federation.go index df6ae948b..78e31668b 100644 --- a/plugin/kubernetes/federation.go +++ b/plugin/kubernetes/federation.go @@ -1,6 +1,8 @@ package kubernetes import ( + "errors" + "github.com/coredns/coredns/plugin/etcd/msg" "github.com/coredns/coredns/plugin/pkg/dnsutil" "github.com/coredns/coredns/request" @@ -37,6 +39,10 @@ func (k *Kubernetes) Federations(state request.Request, fname, fzone string) (ms lz := node.Labels[LabelZone] lr := node.Labels[LabelRegion] + if lz == "" || lr == "" { + return msg.Service{}, errors.New("local node missing zone/region labels") + } + if r.endpoint == "" { return msg.Service{Host: dnsutil.Join([]string{r.service, r.namespace, fname, r.podOrSvc, lz, lr, fzone})}, nil } |