update deprecated interface
@@ -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 {
