kubernetes
/
autoscaler
mirror of https://github.com/kubernetes/autoscaler.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace deprecate kubernetes client functions

This commit is contained in:
Sergey Lanzman 2017-11-09 19:49:41 +02:00
parent ebee07962a
commit eb546b87a0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cluster-autoscaler/utils/drain/drain.go
View File

@ -109,7 +109,7 @@ func GetPodsForDeletionOnNodeDrain(
} }
} else if refKind == "DaemonSet" { } else if refKind == "DaemonSet" {
if checkReferences { if checkReferences {
ds, err := client.Extensions().DaemonSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{}) ds, err := client.ExtensionsV1beta1().DaemonSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{})
// Assume the only reason for an error is because the DaemonSet is // Assume the only reason for an error is because the DaemonSet is
// gone/missing, not for any other cause. TODO(mml): something more // gone/missing, not for any other cause. TODO(mml): something more
@ -128,7 +128,7 @@ func GetPodsForDeletionOnNodeDrain(
} }
} else if refKind == "Job" { } else if refKind == "Job" {
if checkReferences { if checkReferences {
job, err := client.Batch().Jobs(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{}) job, err := client.BatchV1().Jobs(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{})
// Assume the only reason for an error is because the Job is // Assume the only reason for an error is because the Job is
// gone/missing, not for any other cause. TODO(mml): something more // gone/missing, not for any other cause. TODO(mml): something more
@ -143,7 +143,7 @@ func GetPodsForDeletionOnNodeDrain(
} }
} else if refKind == "ReplicaSet" { } else if refKind == "ReplicaSet" {
if checkReferences { if checkReferences {
rs, err := client.Extensions().ReplicaSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{}) rs, err := client.ExtensionsV1beta1().ReplicaSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{})
// Assume the only reason for an error is because the RS is // Assume the only reason for an error is because the RS is
// gone/missing, not for any other cause. TODO(mml): something more // gone/missing, not for any other cause. TODO(mml): something more
@ -162,7 +162,7 @@ func GetPodsForDeletionOnNodeDrain(
} }
} else if refKind == "StatefulSet" { } else if refKind == "StatefulSet" {
if checkReferences { if checkReferences {
ss, err := client.Apps().StatefulSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{}) ss, err := client.AppsV1beta1().StatefulSets(controllerNamespace).Get(controllerRef.Name, metav1.GetOptions{})
// Assume the only reason for an error is because the StatefulSet is // Assume the only reason for an error is because the StatefulSet is
// gone/missing, not for any other cause. TODO(mml): something more // gone/missing, not for any other cause. TODO(mml): something more