diff options
author | 2018-12-14 09:41:51 +0000 | |
---|---|---|
committer | 2018-12-14 09:41:51 +0000 | |
commit | c1c98924c3733b853115c62adc1a2b5978ae2df3 (patch) | |
tree | 6006978128c2ffd02eb9c5eaaeb16993f38f205b /plugin/kubernetes/object/service.go | |
parent | d9880681c3b28f8506e2a5b15bbc404b2a155b00 (diff) | |
download | coredns-c1c98924c3733b853115c62adc1a2b5978ae2df3.tar.gz coredns-c1c98924c3733b853115c62adc1a2b5978ae2df3.tar.zst coredns-c1c98924c3733b853115c62adc1a2b5978ae2df3.zip |
Add new plugin: external - resolve k8s ingress and LB address with external names (#2379)
* Add new plugin: external
This plugin works in conjunction with the kubernetes plugin and exports
ingress and LB addresses as DNS records. It bypasses backend.go and
backend_lookup.go flow because it is not needed.
README, tests are implemented. The tests only exercise the unit tests,
this has not been tested in any ci.
Signed-off-by: Miek Gieben <miek@miek.nl>
* Rename to k8s_external
Signed-off-by: Miek Gieben <miek@miek.nl>
* go gen
Signed-off-by: Miek Gieben <miek@miek.nl>
Diffstat (limited to 'plugin/kubernetes/object/service.go')
-rw-r--r-- | plugin/kubernetes/object/service.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/plugin/kubernetes/object/service.go b/plugin/kubernetes/object/service.go index be010e96b..af9a42b48 100644 --- a/plugin/kubernetes/object/service.go +++ b/plugin/kubernetes/object/service.go @@ -16,6 +16,9 @@ type Service struct { ExternalName string Ports []api.ServicePort + // ExternalIPs we may want to export. + ExternalIPs []string + *Empty } @@ -37,6 +40,8 @@ func ToService(obj interface{}) interface{} { ClusterIP: svc.Spec.ClusterIP, Type: svc.Spec.Type, ExternalName: svc.Spec.ExternalName, + + ExternalIPs: make([]string, len(svc.Status.LoadBalancer.Ingress)+len(svc.Spec.ExternalIPs)), } if len(svc.Spec.Ports) == 0 { @@ -47,6 +52,11 @@ func ToService(obj interface{}) interface{} { copy(s.Ports, svc.Spec.Ports) } + li := copy(s.ExternalIPs, svc.Spec.ExternalIPs) + for i, lb := range svc.Status.LoadBalancer.Ingress { + s.ExternalIPs[li+i] = lb.IP + } + *svc = api.Service{} return s @@ -65,8 +75,10 @@ func (s *Service) DeepCopyObject() runtime.Object { Type: s.Type, ExternalName: s.ExternalName, Ports: make([]api.ServicePort, len(s.Ports)), + ExternalIPs: make([]string, len(s.ExternalIPs)), } copy(s1.Ports, s.Ports) + copy(s1.ExternalIPs, s.ExternalIPs) return s1 } |