mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
clean ups
This commit is contained in:
parent
7bf40d2c60
commit
126716287b
@ -29,8 +29,6 @@ go_library(
|
|||||||
srcs = ["admission.go"],
|
srcs = ["admission.go"],
|
||||||
importpath = "k8s.io/kubernetes/plugin/pkg/admission/podpreset",
|
importpath = "k8s.io/kubernetes/plugin/pkg/admission/podpreset",
|
||||||
deps = [
|
deps = [
|
||||||
"//pkg/api/legacyscheme:go_default_library",
|
|
||||||
"//pkg/api/ref:go_default_library",
|
|
||||||
"//pkg/apis/core:go_default_library",
|
"//pkg/apis/core:go_default_library",
|
||||||
"//pkg/apis/settings:go_default_library",
|
"//pkg/apis/settings:go_default_library",
|
||||||
"//pkg/client/clientset_generated/internalclientset:go_default_library",
|
"//pkg/client/clientset_generated/internalclientset:go_default_library",
|
||||||
|
@ -29,8 +29,6 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/labels"
|
"k8s.io/apimachinery/pkg/labels"
|
||||||
utilerrors "k8s.io/apimachinery/pkg/util/errors"
|
utilerrors "k8s.io/apimachinery/pkg/util/errors"
|
||||||
"k8s.io/apiserver/pkg/admission"
|
"k8s.io/apiserver/pkg/admission"
|
||||||
"k8s.io/kubernetes/pkg/api/legacyscheme"
|
|
||||||
"k8s.io/kubernetes/pkg/api/ref"
|
|
||||||
api "k8s.io/kubernetes/pkg/apis/core"
|
api "k8s.io/kubernetes/pkg/apis/core"
|
||||||
"k8s.io/kubernetes/pkg/apis/settings"
|
"k8s.io/kubernetes/pkg/apis/settings"
|
||||||
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
|
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
|
||||||
@ -347,28 +345,6 @@ func mergeVolumes(volumes []api.Volume, podPresets []*settings.PodPreset) ([]api
|
|||||||
return mergedVolumes, err
|
return mergedVolumes, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *podPresetPlugin) addEvent(pod *api.Pod, pip *settings.PodPreset, message string) {
|
|
||||||
ref, err := ref.GetReference(legacyscheme.Scheme, pod)
|
|
||||||
if err != nil {
|
|
||||||
glog.Errorf("pip %s: get reference for pod %s failed: %v", pip.GetName(), pod.GetName(), err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
e := &api.Event{
|
|
||||||
InvolvedObject: *ref,
|
|
||||||
Message: message,
|
|
||||||
Source: api.EventSource{
|
|
||||||
Component: fmt.Sprintf("pip %s", pip.GetName()),
|
|
||||||
},
|
|
||||||
Type: "Warning",
|
|
||||||
}
|
|
||||||
|
|
||||||
if _, err := c.client.Core().Events(pod.GetNamespace()).Create(e); err != nil {
|
|
||||||
glog.Errorf("pip %s: creating pod event failed: %v", pip.GetName(), err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// applyPodPresetsOnPod updates the PodSpec with merged information from all the
|
// applyPodPresetsOnPod updates the PodSpec with merged information from all the
|
||||||
// applicable PodPresets. It ignores the errors of merge functions because merge
|
// applicable PodPresets. It ignores the errors of merge functions because merge
|
||||||
// errors have already been checked in safeToApplyPodPresetsOnPod function.
|
// errors have already been checked in safeToApplyPodPresetsOnPod function.
|
||||||
|
Loading…
Reference in New Issue
Block a user