mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-27 13:37:30 +00:00
Merge pull request #97650 from ialidzhikov/cleanup/redundant-imports
Clean up some redundant imports
This commit is contained in:
commit
e7dc0df323
@ -29,7 +29,6 @@ import (
|
|||||||
apps "k8s.io/api/apps/v1"
|
apps "k8s.io/api/apps/v1"
|
||||||
v1 "k8s.io/api/core/v1"
|
v1 "k8s.io/api/core/v1"
|
||||||
apiequality "k8s.io/apimachinery/pkg/api/equality"
|
apiequality "k8s.io/apimachinery/pkg/api/equality"
|
||||||
"k8s.io/apimachinery/pkg/api/errors"
|
|
||||||
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
||||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||||
"k8s.io/apimachinery/pkg/labels"
|
"k8s.io/apimachinery/pkg/labels"
|
||||||
@ -1001,7 +1000,7 @@ func (dsc *DaemonSetsController) syncNodes(ds *apps.DaemonSet, podsToDelete, nod
|
|||||||
ds, metav1.NewControllerRef(ds, controllerKind))
|
ds, metav1.NewControllerRef(ds, controllerKind))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.HasStatusCause(err, v1.NamespaceTerminatingCause) {
|
if apierrors.HasStatusCause(err, v1.NamespaceTerminatingCause) {
|
||||||
// If the namespace is being torn down, we can safely ignore
|
// If the namespace is being torn down, we can safely ignore
|
||||||
// this error since all subsequent creations will fail.
|
// this error since all subsequent creations will fail.
|
||||||
return
|
return
|
||||||
@ -1164,7 +1163,7 @@ func (dsc *DaemonSetsController) syncDaemonSet(key string) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
ds, err := dsc.dsLister.DaemonSets(namespace).Get(name)
|
ds, err := dsc.dsLister.DaemonSets(namespace).Get(name)
|
||||||
if errors.IsNotFound(err) {
|
if apierrors.IsNotFound(err) {
|
||||||
klog.V(3).Infof("daemon set has been deleted %v", key)
|
klog.V(3).Infof("daemon set has been deleted %v", key)
|
||||||
dsc.expectations.DeleteExpectations(key)
|
dsc.expectations.DeleteExpectations(key)
|
||||||
return nil
|
return nil
|
||||||
|
@ -38,7 +38,6 @@ import (
|
|||||||
|
|
||||||
apps "k8s.io/api/apps/v1"
|
apps "k8s.io/api/apps/v1"
|
||||||
"k8s.io/api/core/v1"
|
"k8s.io/api/core/v1"
|
||||||
"k8s.io/apimachinery/pkg/api/errors"
|
|
||||||
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
||||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||||
"k8s.io/apimachinery/pkg/labels"
|
"k8s.io/apimachinery/pkg/labels"
|
||||||
@ -568,7 +567,7 @@ func (rsc *ReplicaSetController) manageReplicas(filteredPods []*v1.Pod, rs *apps
|
|||||||
successfulCreations, err := slowStartBatch(diff, controller.SlowStartInitialBatchSize, func() error {
|
successfulCreations, err := slowStartBatch(diff, controller.SlowStartInitialBatchSize, func() error {
|
||||||
err := rsc.podControl.CreatePodsWithControllerRef(rs.Namespace, &rs.Spec.Template, rs, metav1.NewControllerRef(rs, rsc.GroupVersionKind))
|
err := rsc.podControl.CreatePodsWithControllerRef(rs.Namespace, &rs.Spec.Template, rs, metav1.NewControllerRef(rs, rsc.GroupVersionKind))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.HasStatusCause(err, v1.NamespaceTerminatingCause) {
|
if apierrors.HasStatusCause(err, v1.NamespaceTerminatingCause) {
|
||||||
// if the namespace is being terminated, we don't have to do
|
// if the namespace is being terminated, we don't have to do
|
||||||
// anything because any creation will fail
|
// anything because any creation will fail
|
||||||
return nil
|
return nil
|
||||||
@ -654,7 +653,7 @@ func (rsc *ReplicaSetController) syncReplicaSet(key string) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
rs, err := rsc.rsLister.ReplicaSets(namespace).Get(name)
|
rs, err := rsc.rsLister.ReplicaSets(namespace).Get(name)
|
||||||
if errors.IsNotFound(err) {
|
if apierrors.IsNotFound(err) {
|
||||||
klog.V(4).Infof("%v %v has been deleted", rsc.Kind, key)
|
klog.V(4).Infof("%v %v has been deleted", rsc.Kind, key)
|
||||||
rsc.expectations.DeleteExpectations(key)
|
rsc.expectations.DeleteExpectations(key)
|
||||||
return nil
|
return nil
|
||||||
|
Loading…
Reference in New Issue
Block a user