From 9b8ee1c119c8dc2ad3304cffb084e78837716bdb Mon Sep 17 00:00:00 2001 From: Chris O'Haver Date: Fri, 10 Nov 2017 15:38:45 -0500 Subject: [PATCH] plugin/k8s: fix endpoint index creation (#1222) --- plugin/kubernetes/controller.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/plugin/kubernetes/controller.go b/plugin/kubernetes/controller.go index 3cad9e6c2..89b608703 100644 --- a/plugin/kubernetes/controller.go +++ b/plugin/kubernetes/controller.go @@ -145,11 +145,17 @@ func epNameNamespaceIndexFunc(obj interface{}) ([]string, error) { } func epIPIndexFunc(obj interface{}) ([]string, error) { - ep, ok := obj.(*api.EndpointAddress) + ep, ok := obj.(*api.Endpoints) if !ok { - return nil, errors.New("obj was not an *api.EndpointAddress") + return nil, errors.New("obj was not an *api.Endpoints") } - return []string{ep.IP}, nil + var idx []string + for _, eps := range ep.Subsets { + for _, addr := range eps.Addresses { + idx = append(idx, addr.IP) + } + } + return idx, nil } func serviceListFunc(c *kubernetes.Clientset, ns string, s *labels.Selector) func(meta.ListOptions) (runtime.Object, error) {