mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-25 12:43:23 +00:00
apimachinery: Remove cloner from scheme
This commit is contained in:
Dr. Stefan Schimanski
parent
729f5a3b4d
commit
b5b62c6831
@ -309,7 +309,6 @@ func (r *crdHandler) getServingInfoFor(crd *apiextensions.CustomResourceDefiniti
|
|||||||
&metav1.GetOptions{},
|
&metav1.GetOptions{},
|
||||||
&metav1.DeleteOptions{},
|
&metav1.DeleteOptions{},
|
||||||
)
|
)
|
||||||
parameterScheme.AddGeneratedDeepCopyFuncs(metav1.GetGeneratedDeepCopyFuncs()...)
|
|
||||||
parameterCodec := runtime.NewParameterCodec(parameterScheme)
|
parameterCodec := runtime.NewParameterCodec(parameterScheme)
|
||||||
|
|
||||||
kind := schema.GroupVersionKind{Group: crd.Spec.Group, Version: crd.Spec.Version, Kind: crd.Status.AcceptedNames.Kind}
|
kind := schema.GroupVersionKind{Group: crd.Spec.Group, Version: crd.Spec.Version, Kind: crd.Status.AcceptedNames.Kind}
|
||||||
|
|||||||
@ -70,7 +70,6 @@ func AddToGroupVersion(scheme *runtime.Scheme, groupVersion schema.GroupVersion)
|
|||||||
)
|
)
|
||||||
|
|
||||||
// register manually. This usually goes through the SchemeBuilder, which we cannot use here.
|
// register manually. This usually goes through the SchemeBuilder, which we cannot use here.
|
||||||
scheme.AddGeneratedDeepCopyFuncs(GetGeneratedDeepCopyFuncs()...)
|
|
||||||
AddConversionFuncs(scheme)
|
AddConversionFuncs(scheme)
|
||||||
RegisterDefaults(scheme)
|
RegisterDefaults(scheme)
|
||||||
}
|
}
|
||||||
@ -90,6 +89,5 @@ func init() {
|
|||||||
)
|
)
|
||||||
|
|
||||||
// register manually. This usually goes through the SchemeBuilder, which we cannot use here.
|
// register manually. This usually goes through the SchemeBuilder, which we cannot use here.
|
||||||
scheme.AddGeneratedDeepCopyFuncs(GetGeneratedDeepCopyFuncs()...)
|
|
||||||
RegisterDefaults(scheme)
|
RegisterDefaults(scheme)
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,249 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright 2014 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 conversion
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"reflect"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Cloner knows how to copy one type to another.
|
|
||||||
type Cloner struct {
|
|
||||||
// Map from the type to a function which can do the deep copy.
|
|
||||||
deepCopyFuncs map[reflect.Type]reflect.Value
|
|
||||||
generatedDeepCopyFuncs map[reflect.Type]func(in interface{}, out interface{}, c *Cloner) error
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewCloner creates a new Cloner object.
|
|
||||||
func NewCloner() *Cloner {
|
|
||||||
c := &Cloner{
|
|
||||||
deepCopyFuncs: map[reflect.Type]reflect.Value{},
|
|
||||||
generatedDeepCopyFuncs: map[reflect.Type]func(in interface{}, out interface{}, c *Cloner) error{},
|
|
||||||
}
|
|
||||||
if err := c.RegisterDeepCopyFunc(byteSliceDeepCopy); err != nil {
|
|
||||||
// If one of the deep-copy functions is malformed, detect it immediately.
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
return c
|
|
||||||
}
|
|
||||||
|
|
||||||
// Prevent recursing into every byte...
|
|
||||||
func byteSliceDeepCopy(in *[]byte, out *[]byte, c *Cloner) error {
|
|
||||||
if *in != nil {
|
|
||||||
*out = make([]byte, len(*in))
|
|
||||||
copy(*out, *in)
|
|
||||||
} else {
|
|
||||||
*out = nil
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// Verifies whether a deep-copy function has a correct signature.
|
|
||||||
func verifyDeepCopyFunctionSignature(ft reflect.Type) error {
|
|
||||||
if ft.Kind() != reflect.Func {
|
|
||||||
return fmt.Errorf("expected func, got: %v", ft)
|
|
||||||
}
|
|
||||||
if ft.NumIn() != 3 {
|
|
||||||
return fmt.Errorf("expected three 'in' params, got %v", ft)
|
|
||||||
}
|
|
||||||
if ft.NumOut() != 1 {
|
|
||||||
return fmt.Errorf("expected one 'out' param, got %v", ft)
|
|
||||||
}
|
|
||||||
if ft.In(0).Kind() != reflect.Ptr {
|
|
||||||
return fmt.Errorf("expected pointer arg for 'in' param 0, got: %v", ft)
|
|
||||||
}
|
|
||||||
if ft.In(1) != ft.In(0) {
|
|
||||||
return fmt.Errorf("expected 'in' param 0 the same as param 1, got: %v", ft)
|
|
||||||
}
|
|
||||||
var forClonerType Cloner
|
|
||||||
if expected := reflect.TypeOf(&forClonerType); ft.In(2) != expected {
|
|
||||||
return fmt.Errorf("expected '%v' arg for 'in' param 2, got: '%v'", expected, ft.In(2))
|
|
||||||
}
|
|
||||||
var forErrorType error
|
|
||||||
// This convolution is necessary, otherwise TypeOf picks up on the fact
|
|
||||||
// that forErrorType is nil
|
|
||||||
errorType := reflect.TypeOf(&forErrorType).Elem()
|
|
||||||
if ft.Out(0) != errorType {
|
|
||||||
return fmt.Errorf("expected error return, got: %v", ft)
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// RegisterGeneratedDeepCopyFunc registers a copying func with the Cloner.
|
|
||||||
// deepCopyFunc must take three parameters: a type input, a pointer to a
|
|
||||||
// type output, and a pointer to Cloner. It should return an error.
|
|
||||||
//
|
|
||||||
// Example:
|
|
||||||
// c.RegisterGeneratedDeepCopyFunc(
|
|
||||||
// func(in Pod, out *Pod, c *Cloner) error {
|
|
||||||
// // deep copy logic...
|
|
||||||
// return nil
|
|
||||||
// })
|
|
||||||
func (c *Cloner) RegisterDeepCopyFunc(deepCopyFunc interface{}) error {
|
|
||||||
fv := reflect.ValueOf(deepCopyFunc)
|
|
||||||
ft := fv.Type()
|
|
||||||
if err := verifyDeepCopyFunctionSignature(ft); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
c.deepCopyFuncs[ft.In(0)] = fv
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GeneratedDeepCopyFunc bundles an untyped generated deep-copy function of a type
|
|
||||||
// with a reflection type object used as a key to lookup the deep-copy function.
|
|
||||||
type GeneratedDeepCopyFunc struct {
|
|
||||||
Fn func(in interface{}, out interface{}, c *Cloner) error
|
|
||||||
InType reflect.Type
|
|
||||||
}
|
|
||||||
|
|
||||||
// Similar to RegisterDeepCopyFunc, but registers deep copy function that were
|
|
||||||
// automatically generated.
|
|
||||||
func (c *Cloner) RegisterGeneratedDeepCopyFunc(fn GeneratedDeepCopyFunc) error {
|
|
||||||
c.generatedDeepCopyFuncs[fn.InType] = fn.Fn
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// DeepCopy will perform a deep copy of a given object.
|
|
||||||
func (c *Cloner) DeepCopy(in interface{}) (interface{}, error) {
|
|
||||||
// Can be invalid if we run DeepCopy(X) where X is a nil interface type.
|
|
||||||
// For example, we get an invalid value when someone tries to deep-copy
|
|
||||||
// a nil labels.Selector.
|
|
||||||
// This does not occur if X is nil and is a pointer to a concrete type.
|
|
||||||
if in == nil {
|
|
||||||
return nil, nil
|
|
||||||
}
|
|
||||||
inValue := reflect.ValueOf(in)
|
|
||||||
outValue, err := c.deepCopy(inValue)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return outValue.Interface(), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Cloner) deepCopy(src reflect.Value) (reflect.Value, error) {
|
|
||||||
inType := src.Type()
|
|
||||||
|
|
||||||
switch src.Kind() {
|
|
||||||
case reflect.Interface, reflect.Ptr, reflect.Map, reflect.Slice:
|
|
||||||
if src.IsNil() {
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if fv, ok := c.deepCopyFuncs[inType]; ok {
|
|
||||||
return c.customDeepCopy(src, fv)
|
|
||||||
}
|
|
||||||
if fv, ok := c.generatedDeepCopyFuncs[inType]; ok {
|
|
||||||
var outValue reflect.Value
|
|
||||||
outValue = reflect.New(inType.Elem())
|
|
||||||
err := fv(src.Interface(), outValue.Interface(), c)
|
|
||||||
return outValue, err
|
|
||||||
}
|
|
||||||
return c.defaultDeepCopy(src)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Cloner) customDeepCopy(src, fv reflect.Value) (reflect.Value, error) {
|
|
||||||
outValue := reflect.New(src.Type().Elem())
|
|
||||||
args := []reflect.Value{src, outValue, reflect.ValueOf(c)}
|
|
||||||
result := fv.Call(args)[0].Interface()
|
|
||||||
// This convolution is necessary because nil interfaces won't convert
|
|
||||||
// to error.
|
|
||||||
if result == nil {
|
|
||||||
return outValue, nil
|
|
||||||
}
|
|
||||||
return outValue, result.(error)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Cloner) defaultDeepCopy(src reflect.Value) (reflect.Value, error) {
|
|
||||||
switch src.Kind() {
|
|
||||||
case reflect.Chan, reflect.Func, reflect.UnsafePointer, reflect.Uintptr:
|
|
||||||
return src, fmt.Errorf("cannot deep copy kind: %s", src.Kind())
|
|
||||||
case reflect.Array:
|
|
||||||
dst := reflect.New(src.Type())
|
|
||||||
for i := 0; i < src.Len(); i++ {
|
|
||||||
copyVal, err := c.deepCopy(src.Index(i))
|
|
||||||
if err != nil {
|
|
||||||
return src, err
|
|
||||||
}
|
|
||||||
dst.Elem().Index(i).Set(copyVal)
|
|
||||||
}
|
|
||||||
return dst.Elem(), nil
|
|
||||||
case reflect.Interface:
|
|
||||||
if src.IsNil() {
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
return c.deepCopy(src.Elem())
|
|
||||||
case reflect.Map:
|
|
||||||
if src.IsNil() {
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
dst := reflect.MakeMap(src.Type())
|
|
||||||
for _, k := range src.MapKeys() {
|
|
||||||
copyVal, err := c.deepCopy(src.MapIndex(k))
|
|
||||||
if err != nil {
|
|
||||||
return src, err
|
|
||||||
}
|
|
||||||
dst.SetMapIndex(k, copyVal)
|
|
||||||
}
|
|
||||||
return dst, nil
|
|
||||||
case reflect.Ptr:
|
|
||||||
if src.IsNil() {
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
dst := reflect.New(src.Type().Elem())
|
|
||||||
copyVal, err := c.deepCopy(src.Elem())
|
|
||||||
if err != nil {
|
|
||||||
return src, err
|
|
||||||
}
|
|
||||||
dst.Elem().Set(copyVal)
|
|
||||||
return dst, nil
|
|
||||||
case reflect.Slice:
|
|
||||||
if src.IsNil() {
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
dst := reflect.MakeSlice(src.Type(), 0, src.Len())
|
|
||||||
for i := 0; i < src.Len(); i++ {
|
|
||||||
copyVal, err := c.deepCopy(src.Index(i))
|
|
||||||
if err != nil {
|
|
||||||
return src, err
|
|
||||||
}
|
|
||||||
dst = reflect.Append(dst, copyVal)
|
|
||||||
}
|
|
||||||
return dst, nil
|
|
||||||
case reflect.Struct:
|
|
||||||
dst := reflect.New(src.Type())
|
|
||||||
for i := 0; i < src.NumField(); i++ {
|
|
||||||
if !dst.Elem().Field(i).CanSet() {
|
|
||||||
// Can't set private fields. At this point, the
|
|
||||||
// best we can do is a shallow copy. For
|
|
||||||
// example, time.Time is a value type with
|
|
||||||
// private members that can be shallow copied.
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
copyVal, err := c.deepCopy(src.Field(i))
|
|
||||||
if err != nil {
|
|
||||||
return src, err
|
|
||||||
}
|
|
||||||
dst.Elem().Field(i).Set(copyVal)
|
|
||||||
}
|
|
||||||
return dst.Elem(), nil
|
|
||||||
|
|
||||||
default:
|
|
||||||
// Value types like numbers, booleans, and strings.
|
|
||||||
return src, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,161 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright 2015 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 conversion
|
|
||||||
|
|
||||||
import (
|
|
||||||
"math/rand"
|
|
||||||
"reflect"
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/google/gofuzz"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestDeepCopy(t *testing.T) {
|
|
||||||
semantic := EqualitiesOrDie()
|
|
||||||
f := fuzz.New().NilChance(.5).NumElements(0, 100)
|
|
||||||
table := []interface{}{
|
|
||||||
map[string]string{},
|
|
||||||
int(5),
|
|
||||||
"hello world",
|
|
||||||
struct {
|
|
||||||
A, B, C struct {
|
|
||||||
D map[string]int
|
|
||||||
}
|
|
||||||
X []int
|
|
||||||
Y []byte
|
|
||||||
}{},
|
|
||||||
}
|
|
||||||
for _, obj := range table {
|
|
||||||
obj2, err := NewCloner().DeepCopy(obj)
|
|
||||||
if err != nil {
|
|
||||||
t.Errorf("Error: couldn't copy %#v", obj)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if e, a := obj, obj2; !semantic.DeepEqual(e, a) {
|
|
||||||
t.Errorf("expected %#v\ngot %#v", e, a)
|
|
||||||
}
|
|
||||||
|
|
||||||
obj3 := reflect.New(reflect.TypeOf(obj)).Interface()
|
|
||||||
f.Fuzz(obj3)
|
|
||||||
obj4, err := NewCloner().DeepCopy(obj3)
|
|
||||||
if err != nil {
|
|
||||||
t.Errorf("Error: couldn't copy %#v", obj)
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if e, a := obj3, obj4; !semantic.DeepEqual(e, a) {
|
|
||||||
t.Errorf("expected %#v\ngot %#v", e, a)
|
|
||||||
}
|
|
||||||
f.Fuzz(obj3)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func copyOrDie(t *testing.T, in interface{}) interface{} {
|
|
||||||
out, err := NewCloner().DeepCopy(in)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("DeepCopy failed: %#q: %v", in, err)
|
|
||||||
}
|
|
||||||
return out
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDeepCopySliceSeparate(t *testing.T) {
|
|
||||||
x := []int{5}
|
|
||||||
y := copyOrDie(t, x).([]int)
|
|
||||||
x[0] = 3
|
|
||||||
if y[0] == 3 {
|
|
||||||
t.Errorf("deep copy wasn't deep: %#q %#q", x, y)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDeepCopyArraySeparate(t *testing.T) {
|
|
||||||
x := [1]int{5}
|
|
||||||
y := copyOrDie(t, x).([1]int)
|
|
||||||
x[0] = 3
|
|
||||||
if y[0] == 3 {
|
|
||||||
t.Errorf("deep copy wasn't deep: %#q %#q", x, y)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDeepCopyMapSeparate(t *testing.T) {
|
|
||||||
x := map[string]int{"foo": 5}
|
|
||||||
y := copyOrDie(t, x).(map[string]int)
|
|
||||||
x["foo"] = 3
|
|
||||||
if y["foo"] == 3 {
|
|
||||||
t.Errorf("deep copy wasn't deep: %#q %#q", x, y)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDeepCopyPointerSeparate(t *testing.T) {
|
|
||||||
z := 5
|
|
||||||
x := &z
|
|
||||||
y := copyOrDie(t, x).(*int)
|
|
||||||
*x = 3
|
|
||||||
if *y == 3 {
|
|
||||||
t.Errorf("deep copy wasn't deep: %#q %#q", x, y)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDeepCopyStruct(t *testing.T) {
|
|
||||||
type Foo struct {
|
|
||||||
A int
|
|
||||||
}
|
|
||||||
type Bar struct {
|
|
||||||
Foo
|
|
||||||
F *Foo
|
|
||||||
}
|
|
||||||
a := &Bar{Foo{1}, &Foo{2}}
|
|
||||||
b := copyOrDie(t, a).(*Bar)
|
|
||||||
a.A = 3
|
|
||||||
a.F.A = 4
|
|
||||||
|
|
||||||
if b.A != 1 || b.F.A != 2 {
|
|
||||||
t.Errorf("deep copy wasn't deep: %#v, %#v", a, b)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var result interface{}
|
|
||||||
|
|
||||||
func BenchmarkDeepCopy(b *testing.B) {
|
|
||||||
table := []interface{}{
|
|
||||||
map[string]string{},
|
|
||||||
int(5),
|
|
||||||
"hello world",
|
|
||||||
struct {
|
|
||||||
A, B, C struct {
|
|
||||||
D map[string]int
|
|
||||||
}
|
|
||||||
X []int
|
|
||||||
Y []byte
|
|
||||||
}{},
|
|
||||||
}
|
|
||||||
|
|
||||||
f := fuzz.New().RandSource(rand.NewSource(1)).NilChance(.5).NumElements(0, 100)
|
|
||||||
for i := range table {
|
|
||||||
out := table[i]
|
|
||||||
obj := reflect.New(reflect.TypeOf(out)).Interface()
|
|
||||||
f.Fuzz(obj)
|
|
||||||
table[i] = obj
|
|
||||||
}
|
|
||||||
|
|
||||||
b.ResetTimer()
|
|
||||||
var r interface{}
|
|
||||||
for i := 0; i < b.N; i++ {
|
|
||||||
for j := range table {
|
|
||||||
r, _ = NewCloner().DeepCopy(table[j])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
result = r
|
|
||||||
}
|
|
||||||
@ -49,6 +49,5 @@ func addKnownTypes(scheme *runtime.Scheme) error {
|
|||||||
&Policy{},
|
&Policy{},
|
||||||
&PolicyList{},
|
&PolicyList{},
|
||||||
)
|
)
|
||||||
scheme.AddGeneratedDeepCopyFuncs(GetGeneratedDeepCopyFuncs()...)
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user