diff options
Diffstat (limited to 'core/setup/kubernetes.go')
| -rw-r--r-- | core/setup/kubernetes.go | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/core/setup/kubernetes.go b/core/setup/kubernetes.go index 17b37e00e..7439a9f1b 100644 --- a/core/setup/kubernetes.go +++ b/core/setup/kubernetes.go @@ -10,6 +10,7 @@ import ( "github.com/miekg/coredns/middleware" "github.com/miekg/coredns/middleware/kubernetes" "github.com/miekg/coredns/middleware/kubernetes/nametemplate" + unversionedapi "k8s.io/kubernetes/pkg/api/unversioned" ) const ( @@ -109,6 +110,20 @@ func kubernetesParse(c *Controller) (kubernetes.Kubernetes, error) { log.Printf("[debug] 'resyncperiod' keyword provided without any duration value.") return kubernetes.Kubernetes{}, c.ArgErr() } + case "labels": + args := c.RemainingArgs() + if len(args) != 0 { + labelSelectorString := strings.Join(args, " ") + k8s.LabelSelector, err = unversionedapi.ParseToLabelSelector(labelSelectorString) + if err != nil { + err = errors.New(fmt.Sprintf("Unable to parse label selector. Value provided was '%v'. Error was: %v", labelSelectorString, err)) + log.Printf("[ERROR] %v", err) + return kubernetes.Kubernetes{}, err + } + } else { + log.Printf("[debug] 'labels' keyword provided without any selector value.") + return kubernetes.Kubernetes{}, c.ArgErr() + } } } return k8s, nil |