github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 17:30:00 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #125002 from jmcgrath207/revert-122631-disable-service-links

Browse Source 
Revert "DisableServiceLinks admission controller"
This commit is contained in:
Kubernetes Prow Robot 2024-05-20 11:39:33 -07:00 committed by GitHub
commit 7b73bc472c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 0 additions and 180 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/kubeapiserver/options/plugins.go
View File

@ -31,7 +31,6 @@ import (
certsubjectrestriction "k8s.io/kubernetes/plugin/pkg/admission/certificates/subjectrestriction" certsubjectrestriction "k8s.io/kubernetes/plugin/pkg/admission/certificates/subjectrestriction"
"k8s.io/kubernetes/plugin/pkg/admission/defaulttolerationseconds" "k8s.io/kubernetes/plugin/pkg/admission/defaulttolerationseconds"
"k8s.io/kubernetes/plugin/pkg/admission/deny" "k8s.io/kubernetes/plugin/pkg/admission/deny"
"k8s.io/kubernetes/plugin/pkg/admission/disableservicelinks"
"k8s.io/kubernetes/plugin/pkg/admission/eventratelimit" "k8s.io/kubernetes/plugin/pkg/admission/eventratelimit"
"k8s.io/kubernetes/plugin/pkg/admission/extendedresourcetoleration" "k8s.io/kubernetes/plugin/pkg/admission/extendedresourcetoleration"
"k8s.io/kubernetes/plugin/pkg/admission/gc" "k8s.io/kubernetes/plugin/pkg/admission/gc"
@ -92,7 +91,6 @@ var AllOrderedPlugins = []string{
certsubjectrestriction.PluginName, // CertificateSubjectRestriction certsubjectrestriction.PluginName, // CertificateSubjectRestriction
defaultingressclass.PluginName, // DefaultIngressClass defaultingressclass.PluginName, // DefaultIngressClass
denyserviceexternalips.PluginName, // DenyServiceExternalIPs denyserviceexternalips.PluginName, // DenyServiceExternalIPs
disableservicelinks.PluginName, // DisableServiceLinks
// new admission plugins should generally be inserted above here // new admission plugins should generally be inserted above here
// webhook, resourcequota, and deny plugins must go at the end // webhook, resourcequota, and deny plugins must go at the end
@ -114,7 +112,6 @@ func RegisterAllAdmissionPlugins(plugins *admission.Plugins) {
defaultingressclass.Register(plugins) defaultingressclass.Register(plugins)
denyserviceexternalips.Register(plugins) denyserviceexternalips.Register(plugins)
deny.Register(plugins) // DEPRECATED as no real meaning deny.Register(plugins) // DEPRECATED as no real meaning
disableservicelinks.Register(plugins)
eventratelimit.Register(plugins) eventratelimit.Register(plugins)
extendedresourcetoleration.Register(plugins) extendedresourcetoleration.Register(plugins)
gc.Register(plugins) gc.Register(plugins)

76
plugin/pkg/admission/disableservicelinks/admission.go
View File

@ -1,76 +0,0 @@
/*
Copyright 2024 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package disableservicelinks
import (
"context"
"fmt"
"io"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apiserver/pkg/admission"
"k8s.io/kubernetes/pkg/apis/core"
"k8s.io/utils/ptr"
)
// PluginName indicates name of admission plugin.
const PluginName = "DisableServiceLinks"
// Register is called by the apiserver to register the plugin factory.
func Register(plugins *admission.Plugins) {
plugins.Register(PluginName, func(config io.Reader) (admission.Interface, error) {
return newDisableServiceLinks(), nil
})
}
// newDisableServiceLinks creates a new instance of the DisableServiceLinks admission controller.
func newDisableServiceLinks() *plugin {
return &plugin{
Handler: admission.NewHandler(admission.Create, admission.Update),
}
}
// Make sure we are implementing the interface.
var _ admission.MutationInterface = &plugin{}
type plugin struct {
*admission.Handler
}
// Admit updates the EnableServiceLinks of a pod and set it to false.
func (p *plugin) Admit(ctx context.Context, attributes admission.Attributes, o admission.ObjectInterfaces) error {
op := attributes.GetOperation()
// noop admission.Update for future support
if op == admission.Update {
return nil
}
// Ignore all calls to subresources or resources other than pods.
if len(attributes.GetSubresource()) != 0 || attributes.GetResource().GroupResource() != core.Resource("pods") {
return nil
}
pod, ok := attributes.GetObject().(*core.Pod)
if !ok {
return errors.NewBadRequest(fmt.Sprintf("expected *core.Pod but got %T", attributes.GetObject()))
}
pod.Spec.EnableServiceLinks = ptr.To(false)
return nil
}

101
plugin/pkg/admission/disableservicelinks/admission_test.go
View File

@ -1,101 +0,0 @@
/*
Copyright 2024 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package disableservicelinks
import (
"context"
"testing"
"k8s.io/apiserver/pkg/admission"
admissiontesting "k8s.io/apiserver/pkg/admission/testing"
"k8s.io/kubernetes/pkg/apis/core"
"k8s.io/kubernetes/pkg/apis/core/helper"
"k8s.io/utils/ptr"
)
func TestAdmit(t *testing.T) {
plugin := admissiontesting.WithReinvocationTesting(t, newDisableServiceLinks())
tests := []struct {
description string
requestedPod core.Pod
expectedPod core.Pod
operation admission.Operation
}{
{
description: "Create empty pod with default value of Spec.EnableServiceLinks",
requestedPod: core.Pod{
Spec: core.PodSpec{},
},
expectedPod: core.Pod{
Spec: core.PodSpec{EnableServiceLinks: ptr.To(false)},
},
operation: admission.Create,
},
{
description: "Create empty pod with Spec.EnableServiceLinks set to true",
requestedPod: core.Pod{
Spec: core.PodSpec{EnableServiceLinks: ptr.To(true)},
},
expectedPod: core.Pod{
Spec: core.PodSpec{EnableServiceLinks: ptr.To(false)},
},
operation: admission.Create,
},
{
description: "Update empty pod with Spec.EnableServiceLinks set to true",
requestedPod: core.Pod{
Spec: core.PodSpec{EnableServiceLinks: ptr.To(true)},
},
expectedPod: core.Pod{
Spec: core.PodSpec{EnableServiceLinks: ptr.To(true)},
},
operation: admission.Update,
},
}
for i, test := range tests {
err := plugin.Admit(context.TODO(), admission.NewAttributesRecord(&test.requestedPod, nil,
core.Kind("Pod").WithVersion("version"), "foo", "name",
core.Resource("pods").WithVersion("version"), "", test.operation,
nil, false, nil), nil)
if err != nil {
t.Errorf("[%d: %s] unexpected error %v for pod %+v", i, test.description, err, test.requestedPod)
}
if !helper.Semantic.DeepEqual(test.expectedPod.Spec, test.requestedPod.Spec) {
t.Errorf("[%d: %s] expected %t got %t", i, test.description, *test.expectedPod.Spec.EnableServiceLinks, *test.requestedPod.Spec.EnableServiceLinks)
}
}
}
func TestHandles(t *testing.T) {
plugin := newDisableServiceLinks()
tests := map[admission.Operation]bool{
admission.Create: true,
admission.Update: true,
admission.Delete: false,
admission.Connect: false,
}
for op, expected := range tests {
result := plugin.Handles(op)
if result != expected {
t.Errorf("Unexpected result for operation %s: %v\n", op, result)
}
}
}