mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-27 13:37:30 +00:00
DaemonSet: Set DefaultGarbageCollectionPolicy to OrphanDependents.
Now that DaemonSet adds ControllerRef to Pods it creates, we need to set this default so legacy behavior is maintained.
This commit is contained in:
parent
8f3a56f582
commit
2217363845
@ -25,6 +25,7 @@ go_library(
|
|||||||
"//vendor:k8s.io/apimachinery/pkg/util/validation/field",
|
"//vendor:k8s.io/apimachinery/pkg/util/validation/field",
|
||||||
"//vendor:k8s.io/apiserver/pkg/endpoints/request",
|
"//vendor:k8s.io/apiserver/pkg/endpoints/request",
|
||||||
"//vendor:k8s.io/apiserver/pkg/registry/generic",
|
"//vendor:k8s.io/apiserver/pkg/registry/generic",
|
||||||
|
"//vendor:k8s.io/apiserver/pkg/registry/rest",
|
||||||
"//vendor:k8s.io/apiserver/pkg/storage",
|
"//vendor:k8s.io/apiserver/pkg/storage",
|
||||||
"//vendor:k8s.io/apiserver/pkg/storage/names",
|
"//vendor:k8s.io/apiserver/pkg/storage/names",
|
||||||
],
|
],
|
||||||
@ -40,6 +41,7 @@ go_test(
|
|||||||
"//pkg/api/testapi:go_default_library",
|
"//pkg/api/testapi:go_default_library",
|
||||||
"//pkg/api/testing:go_default_library",
|
"//pkg/api/testing:go_default_library",
|
||||||
"//pkg/apis/extensions:go_default_library",
|
"//pkg/apis/extensions:go_default_library",
|
||||||
|
"//vendor:k8s.io/apiserver/pkg/registry/rest",
|
||||||
],
|
],
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -26,6 +26,7 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/util/validation/field"
|
"k8s.io/apimachinery/pkg/util/validation/field"
|
||||||
genericapirequest "k8s.io/apiserver/pkg/endpoints/request"
|
genericapirequest "k8s.io/apiserver/pkg/endpoints/request"
|
||||||
"k8s.io/apiserver/pkg/registry/generic"
|
"k8s.io/apiserver/pkg/registry/generic"
|
||||||
|
"k8s.io/apiserver/pkg/registry/rest"
|
||||||
"k8s.io/apiserver/pkg/storage"
|
"k8s.io/apiserver/pkg/storage"
|
||||||
"k8s.io/apiserver/pkg/storage/names"
|
"k8s.io/apiserver/pkg/storage/names"
|
||||||
"k8s.io/kubernetes/pkg/api"
|
"k8s.io/kubernetes/pkg/api"
|
||||||
@ -42,6 +43,12 @@ type daemonSetStrategy struct {
|
|||||||
// Strategy is the default logic that applies when creating and updating DaemonSet objects.
|
// Strategy is the default logic that applies when creating and updating DaemonSet objects.
|
||||||
var Strategy = daemonSetStrategy{api.Scheme, names.SimpleNameGenerator}
|
var Strategy = daemonSetStrategy{api.Scheme, names.SimpleNameGenerator}
|
||||||
|
|
||||||
|
// DefaultGarbageCollectionPolicy returns Orphan because that was the default
|
||||||
|
// behavior before the server-side garbage collection was implemented.
|
||||||
|
func (daemonSetStrategy) DefaultGarbageCollectionPolicy() rest.GarbageCollectionPolicy {
|
||||||
|
return rest.OrphanDependents
|
||||||
|
}
|
||||||
|
|
||||||
// NamespaceScoped returns true because all DaemonSets need to be within a namespace.
|
// NamespaceScoped returns true because all DaemonSets need to be within a namespace.
|
||||||
func (daemonSetStrategy) NamespaceScoped() bool {
|
func (daemonSetStrategy) NamespaceScoped() bool {
|
||||||
return true
|
return true
|
||||||
|
@ -19,6 +19,7 @@ package daemonset
|
|||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"k8s.io/apiserver/pkg/registry/rest"
|
||||||
_ "k8s.io/kubernetes/pkg/api"
|
_ "k8s.io/kubernetes/pkg/api"
|
||||||
"k8s.io/kubernetes/pkg/api/testapi"
|
"k8s.io/kubernetes/pkg/api/testapi"
|
||||||
apitesting "k8s.io/kubernetes/pkg/api/testing"
|
apitesting "k8s.io/kubernetes/pkg/api/testing"
|
||||||
@ -33,3 +34,12 @@ func TestSelectableFieldLabelConversions(t *testing.T) {
|
|||||||
nil,
|
nil,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestDefaultGarbageCollectionPolicy(t *testing.T) {
|
||||||
|
// Make sure we correctly implement the interface.
|
||||||
|
// Otherwise a typo could silently change the default.
|
||||||
|
var gcds rest.GarbageCollectionDeleteStrategy = Strategy
|
||||||
|
if got, want := gcds.DefaultGarbageCollectionPolicy(), rest.OrphanDependents; got != want {
|
||||||
|
t.Errorf("DefaultGarbageCollectionPolicy() = %#v, want %#v", got, want)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user