From a1d04a7397e93e7bf52987e73d6b4891161d1aad Mon Sep 17 00:00:00 2001 From: hzxuzhonghu Date: Sat, 9 Sep 2017 16:19:58 +0800 Subject: [PATCH] update deprecated interface --- core/pkg/ingress/status/status.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/pkg/ingress/status/status.go b/core/pkg/ingress/status/status.go index 2d126465b..7239a7f49 100644 --- a/core/pkg/ingress/status/status.go +++ b/core/pkg/ingress/status/status.go @@ -218,7 +218,7 @@ func NewStatusSyncer(config Config) Sync { lock := resourcelock.ConfigMapLock{ ConfigMapMeta: meta_v1.ObjectMeta{Namespace: pod.Namespace, Name: electionID}, - Client: config.Client.Core(), + Client: config.Client.CoreV1(), LockConfig: resourcelock.ResourceLockConfig{ Identity: electionID, EventRecorder: recorder, @@ -246,7 +246,7 @@ func NewStatusSyncer(config Config) Sync { func (s *statusSync) runningAddresses() ([]string, error) { if s.PublishService != "" { ns, name, _ := k8s.ParseNameNS(s.PublishService) - svc, err := s.Client.Core().Services(ns).Get(name, meta_v1.GetOptions{}) + svc, err := s.Client.CoreV1().Services(ns).Get(name, meta_v1.GetOptions{}) if err != nil { return nil, err } @@ -267,7 +267,7 @@ func (s *statusSync) runningAddresses() ([]string, error) { } // get information about all the pods running the ingress controller - pods, err := s.Client.Core().Pods(s.pod.Namespace).List(meta_v1.ListOptions{ + pods, err := s.Client.CoreV1().Pods(s.pod.Namespace).List(meta_v1.ListOptions{ LabelSelector: labels.SelectorFromSet(s.pod.Labels).String(), }) if err != nil { @@ -285,7 +285,7 @@ func (s *statusSync) runningAddresses() ([]string, error) { } func (s *statusSync) isRunningMultiplePods() bool { - pods, err := s.Client.Core().Pods(s.pod.Namespace).List(meta_v1.ListOptions{ + pods, err := s.Client.CoreV1().Pods(s.pod.Namespace).List(meta_v1.ListOptions{ LabelSelector: labels.SelectorFromSet(s.pod.Labels).String(), }) if err != nil {