Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
ba95744b
Unverified
Commit
ba95744b
authored
Jul 03, 2018
by
Clayton Coleman
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Make conversion function names match expected values
parent
bd0e4edd
Hide whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
61 additions
and
83 deletions
+61
-83
serialization_test.go
pkg/api/testing/serialization_test.go
+1
-1
conversion.go
pkg/apis/core/v1/conversion.go
+18
-18
conversion_test.go
pkg/apis/core/v1/conversion_test.go
+2
-2
conversion.go
pkg/controller/replication/conversion.go
+2
-2
conversion.go
.../apimachinery/pkg/apis/meta/internalversion/conversion.go
+0
-23
register.go
...io/apimachinery/pkg/apis/meta/internalversion/register.go
+2
-2
conversion.go
...ng/src/k8s.io/apimachinery/pkg/apis/meta/v1/conversion.go
+20
-19
conversion_test.go
...c/k8s.io/apimachinery/pkg/apis/meta/v1/conversion_test.go
+4
-4
register.go
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/register.go
+4
-4
watch.go
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/watch.go
+6
-6
watch.go
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
+2
-2
No files found.
pkg/api/testing/serialization_test.go
View file @
ba95744b
...
...
@@ -72,7 +72,7 @@ func Convert_v1beta1_ReplicaSet_to_api_ReplicationController(in *v1beta1.Replica
}
intermediate2
:=
&
v1
.
ReplicationController
{}
if
err
:=
k8s_api_v1
.
Convert_extensions_ReplicaSet_
t
o_v1_ReplicationController
(
intermediate1
,
intermediate2
,
s
);
err
!=
nil
{
if
err
:=
k8s_api_v1
.
Convert_extensions_ReplicaSet_
T
o_v1_ReplicationController
(
intermediate1
,
intermediate2
,
s
);
err
!=
nil
{
return
err
}
...
...
pkg/apis/core/v1/conversion.go
View file @
ba95744b
...
...
@@ -142,12 +142,12 @@ func addConversionFuncs(scheme *runtime.Scheme) error {
Convert_v1_Secret_To_core_Secret
,
Convert_v1_ServiceSpec_To_core_ServiceSpec
,
Convert_v1_ResourceList_To_core_ResourceList
,
Convert_v1_ReplicationController_
t
o_extensions_ReplicaSet
,
Convert_v1_ReplicationControllerSpec_
t
o_extensions_ReplicaSetSpec
,
Convert_v1_ReplicationControllerStatus_
t
o_extensions_ReplicaSetStatus
,
Convert_extensions_ReplicaSet_
t
o_v1_ReplicationController
,
Convert_extensions_ReplicaSetSpec_
t
o_v1_ReplicationControllerSpec
,
Convert_extensions_ReplicaSetStatus_
t
o_v1_ReplicationControllerStatus
,
Convert_v1_ReplicationController_
T
o_extensions_ReplicaSet
,
Convert_v1_ReplicationControllerSpec_
T
o_extensions_ReplicaSetSpec
,
Convert_v1_ReplicationControllerStatus_
T
o_extensions_ReplicaSetStatus
,
Convert_extensions_ReplicaSet_
T
o_v1_ReplicationController
,
Convert_extensions_ReplicaSetSpec_
T
o_v1_ReplicationControllerSpec
,
Convert_extensions_ReplicaSetStatus_
T
o_v1_ReplicationControllerStatus
,
)
if
err
!=
nil
{
return
err
...
...
@@ -218,23 +218,23 @@ func addConversionFuncs(scheme *runtime.Scheme) error {
return
nil
}
func
Convert_v1_ReplicationController_
t
o_extensions_ReplicaSet
(
in
*
v1
.
ReplicationController
,
out
*
extensions
.
ReplicaSet
,
s
conversion
.
Scope
)
error
{
func
Convert_v1_ReplicationController_
T
o_extensions_ReplicaSet
(
in
*
v1
.
ReplicationController
,
out
*
extensions
.
ReplicaSet
,
s
conversion
.
Scope
)
error
{
out
.
ObjectMeta
=
in
.
ObjectMeta
if
err
:=
Convert_v1_ReplicationControllerSpec_
t
o_extensions_ReplicaSetSpec
(
&
in
.
Spec
,
&
out
.
Spec
,
s
);
err
!=
nil
{
if
err
:=
Convert_v1_ReplicationControllerSpec_
T
o_extensions_ReplicaSetSpec
(
&
in
.
Spec
,
&
out
.
Spec
,
s
);
err
!=
nil
{
return
err
}
if
err
:=
Convert_v1_ReplicationControllerStatus_
t
o_extensions_ReplicaSetStatus
(
&
in
.
Status
,
&
out
.
Status
,
s
);
err
!=
nil
{
if
err
:=
Convert_v1_ReplicationControllerStatus_
T
o_extensions_ReplicaSetStatus
(
&
in
.
Status
,
&
out
.
Status
,
s
);
err
!=
nil
{
return
err
}
return
nil
}
func
Convert_v1_ReplicationControllerSpec_
t
o_extensions_ReplicaSetSpec
(
in
*
v1
.
ReplicationControllerSpec
,
out
*
extensions
.
ReplicaSetSpec
,
s
conversion
.
Scope
)
error
{
func
Convert_v1_ReplicationControllerSpec_
T
o_extensions_ReplicaSetSpec
(
in
*
v1
.
ReplicationControllerSpec
,
out
*
extensions
.
ReplicaSetSpec
,
s
conversion
.
Scope
)
error
{
out
.
Replicas
=
*
in
.
Replicas
out
.
MinReadySeconds
=
in
.
MinReadySeconds
if
in
.
Selector
!=
nil
{
out
.
Selector
=
new
(
metav1
.
LabelSelector
)
metav1
.
Convert_
map_to_unversioned
_LabelSelector
(
&
in
.
Selector
,
out
.
Selector
,
s
)
metav1
.
Convert_
Map_string_To_string_To_v1
_LabelSelector
(
&
in
.
Selector
,
out
.
Selector
,
s
)
}
if
in
.
Template
!=
nil
{
if
err
:=
Convert_v1_PodTemplateSpec_To_core_PodTemplateSpec
(
in
.
Template
,
&
out
.
Template
,
s
);
err
!=
nil
{
...
...
@@ -244,7 +244,7 @@ func Convert_v1_ReplicationControllerSpec_to_extensions_ReplicaSetSpec(in *v1.Re
return
nil
}
func
Convert_v1_ReplicationControllerStatus_
t
o_extensions_ReplicaSetStatus
(
in
*
v1
.
ReplicationControllerStatus
,
out
*
extensions
.
ReplicaSetStatus
,
s
conversion
.
Scope
)
error
{
func
Convert_v1_ReplicationControllerStatus_
T
o_extensions_ReplicaSetStatus
(
in
*
v1
.
ReplicationControllerStatus
,
out
*
extensions
.
ReplicaSetStatus
,
s
conversion
.
Scope
)
error
{
out
.
Replicas
=
in
.
Replicas
out
.
FullyLabeledReplicas
=
in
.
FullyLabeledReplicas
out
.
ReadyReplicas
=
in
.
ReadyReplicas
...
...
@@ -262,9 +262,9 @@ func Convert_v1_ReplicationControllerStatus_to_extensions_ReplicaSetStatus(in *v
return
nil
}
func
Convert_extensions_ReplicaSet_
t
o_v1_ReplicationController
(
in
*
extensions
.
ReplicaSet
,
out
*
v1
.
ReplicationController
,
s
conversion
.
Scope
)
error
{
func
Convert_extensions_ReplicaSet_
T
o_v1_ReplicationController
(
in
*
extensions
.
ReplicaSet
,
out
*
v1
.
ReplicationController
,
s
conversion
.
Scope
)
error
{
out
.
ObjectMeta
=
in
.
ObjectMeta
if
err
:=
Convert_extensions_ReplicaSetSpec_
t
o_v1_ReplicationControllerSpec
(
&
in
.
Spec
,
&
out
.
Spec
,
s
);
err
!=
nil
{
if
err
:=
Convert_extensions_ReplicaSetSpec_
T
o_v1_ReplicationControllerSpec
(
&
in
.
Spec
,
&
out
.
Spec
,
s
);
err
!=
nil
{
fieldErr
,
ok
:=
err
.
(
*
field
.
Error
)
if
!
ok
{
return
err
...
...
@@ -274,19 +274,19 @@ func Convert_extensions_ReplicaSet_to_v1_ReplicationController(in *extensions.Re
}
out
.
Annotations
[
v1
.
NonConvertibleAnnotationPrefix
+
"/"
+
fieldErr
.
Field
]
=
reflect
.
ValueOf
(
fieldErr
.
BadValue
)
.
String
()
}
if
err
:=
Convert_extensions_ReplicaSetStatus_
t
o_v1_ReplicationControllerStatus
(
&
in
.
Status
,
&
out
.
Status
,
s
);
err
!=
nil
{
if
err
:=
Convert_extensions_ReplicaSetStatus_
T
o_v1_ReplicationControllerStatus
(
&
in
.
Status
,
&
out
.
Status
,
s
);
err
!=
nil
{
return
err
}
return
nil
}
func
Convert_extensions_ReplicaSetSpec_
t
o_v1_ReplicationControllerSpec
(
in
*
extensions
.
ReplicaSetSpec
,
out
*
v1
.
ReplicationControllerSpec
,
s
conversion
.
Scope
)
error
{
func
Convert_extensions_ReplicaSetSpec_
T
o_v1_ReplicationControllerSpec
(
in
*
extensions
.
ReplicaSetSpec
,
out
*
v1
.
ReplicationControllerSpec
,
s
conversion
.
Scope
)
error
{
out
.
Replicas
=
new
(
int32
)
*
out
.
Replicas
=
in
.
Replicas
out
.
MinReadySeconds
=
in
.
MinReadySeconds
var
invalidErr
error
if
in
.
Selector
!=
nil
{
invalidErr
=
metav1
.
Convert_
unversioned_LabelSelector_to_map
(
in
.
Selector
,
&
out
.
Selector
,
s
)
invalidErr
=
metav1
.
Convert_
v1_LabelSelector_To_Map_string_To_string
(
in
.
Selector
,
&
out
.
Selector
,
s
)
}
out
.
Template
=
new
(
v1
.
PodTemplateSpec
)
if
err
:=
Convert_core_PodTemplateSpec_To_v1_PodTemplateSpec
(
&
in
.
Template
,
out
.
Template
,
s
);
err
!=
nil
{
...
...
@@ -295,7 +295,7 @@ func Convert_extensions_ReplicaSetSpec_to_v1_ReplicationControllerSpec(in *exten
return
invalidErr
}
func
Convert_extensions_ReplicaSetStatus_
t
o_v1_ReplicationControllerStatus
(
in
*
extensions
.
ReplicaSetStatus
,
out
*
v1
.
ReplicationControllerStatus
,
s
conversion
.
Scope
)
error
{
func
Convert_extensions_ReplicaSetStatus_
T
o_v1_ReplicationControllerStatus
(
in
*
extensions
.
ReplicaSetStatus
,
out
*
v1
.
ReplicationControllerStatus
,
s
conversion
.
Scope
)
error
{
out
.
Replicas
=
in
.
Replicas
out
.
FullyLabeledReplicas
=
in
.
FullyLabeledReplicas
out
.
ReadyReplicas
=
in
.
ReadyReplicas
...
...
pkg/apis/core/v1/conversion_test.go
View file @
ba95744b
...
...
@@ -307,14 +307,14 @@ func TestReplicationControllerConversion(t *testing.T) {
for
_
,
in
:=
range
inputs
{
rs
:=
&
extensions
.
ReplicaSet
{}
// Use in.DeepCopy() to avoid sharing pointers with `in`.
if
err
:=
corev1
.
Convert_v1_ReplicationController_
t
o_extensions_ReplicaSet
(
in
.
DeepCopy
(),
rs
,
nil
);
err
!=
nil
{
if
err
:=
corev1
.
Convert_v1_ReplicationController_
T
o_extensions_ReplicaSet
(
in
.
DeepCopy
(),
rs
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"can't convert RC to RS: %v"
,
err
)
continue
}
// Round-trip RS before converting back to RC.
rs
=
roundTripRS
(
t
,
rs
)
out
:=
&
v1
.
ReplicationController
{}
if
err
:=
corev1
.
Convert_extensions_ReplicaSet_
t
o_v1_ReplicationController
(
rs
,
out
,
nil
);
err
!=
nil
{
if
err
:=
corev1
.
Convert_extensions_ReplicaSet_
T
o_v1_ReplicationController
(
rs
,
out
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"can't convert RS to RC: %v"
,
err
)
continue
}
...
...
pkg/controller/replication/conversion.go
View file @
ba95744b
...
...
@@ -277,7 +277,7 @@ func convertCall(fn func(*v1.ReplicationController) (*v1.ReplicationController,
func
convertRCtoRS
(
rc
*
v1
.
ReplicationController
,
out
*
apps
.
ReplicaSet
)
(
*
apps
.
ReplicaSet
,
error
)
{
var
rsInternal
extensions
.
ReplicaSet
if
err
:=
apiv1
.
Convert_v1_ReplicationController_
t
o_extensions_ReplicaSet
(
rc
,
&
rsInternal
,
nil
);
err
!=
nil
{
if
err
:=
apiv1
.
Convert_v1_ReplicationController_
T
o_extensions_ReplicaSet
(
rc
,
&
rsInternal
,
nil
);
err
!=
nil
{
return
nil
,
fmt
.
Errorf
(
"can't convert ReplicationController %v/%v to ReplicaSet: %v"
,
rc
.
Namespace
,
rc
.
Name
,
err
)
}
if
out
==
nil
{
...
...
@@ -295,7 +295,7 @@ func convertRStoRC(rs *apps.ReplicaSet) (*v1.ReplicationController, error) {
return
nil
,
fmt
.
Errorf
(
"can't convert ReplicaSet (converting to ReplicationController %v/%v) from extensions/v1beta1 to internal: %v"
,
rs
.
Namespace
,
rs
.
Name
,
err
)
}
var
rc
v1
.
ReplicationController
if
err
:=
apiv1
.
Convert_extensions_ReplicaSet_
t
o_v1_ReplicationController
(
&
rsInternal
,
&
rc
,
nil
);
err
!=
nil
{
if
err
:=
apiv1
.
Convert_extensions_ReplicaSet_
T
o_v1_ReplicationController
(
&
rsInternal
,
&
rc
,
nil
);
err
!=
nil
{
return
nil
,
fmt
.
Errorf
(
"can't convert ReplicaSet to ReplicationController %v/%v: %v"
,
rs
.
Namespace
,
rs
.
Name
,
err
)
}
return
&
rc
,
nil
...
...
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/conversion.go
View file @
ba95744b
...
...
@@ -17,11 +17,8 @@ limitations under the License.
package
internalversion
import
(
"fmt"
metav1
"k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/conversion"
"k8s.io/apimachinery/pkg/util/validation/field"
)
func
Convert_internalversion_ListOptions_To_v1_ListOptions
(
in
*
ListOptions
,
out
*
metav1
.
ListOptions
,
s
conversion
.
Scope
)
error
{
...
...
@@ -55,23 +52,3 @@ func Convert_v1_ListOptions_To_internalversion_ListOptions(in *metav1.ListOption
out
.
Continue
=
in
.
Continue
return
nil
}
func
Convert_map_to_v1_LabelSelector
(
in
*
map
[
string
]
string
,
out
*
metav1
.
LabelSelector
,
s
conversion
.
Scope
)
error
{
if
in
==
nil
{
return
nil
}
out
=
new
(
metav1
.
LabelSelector
)
for
labelKey
,
labelValue
:=
range
*
in
{
metav1
.
AddLabelToSelector
(
out
,
labelKey
,
labelValue
)
}
return
nil
}
func
Convert_v1_LabelSelector_to_map
(
in
*
metav1
.
LabelSelector
,
out
*
map
[
string
]
string
,
s
conversion
.
Scope
)
error
{
var
err
error
*
out
,
err
=
metav1
.
LabelSelectorAsMap
(
in
)
if
err
!=
nil
{
err
=
field
.
Invalid
(
field
.
NewPath
(
"labelSelector"
),
*
in
,
fmt
.
Sprintf
(
"cannot convert to old selector: %v"
,
err
))
}
return
err
}
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/register.go
View file @
ba95744b
...
...
@@ -64,8 +64,8 @@ func addToGroupVersion(scheme *runtime.Scheme, groupVersion schema.GroupVersion)
metav1
.
Convert_string_To_fields_Selector
,
metav1
.
Convert_fields_Selector_To_string
,
Convert_map_t
o_v1_LabelSelector
,
Convert_v1_LabelSelector_to_map
,
metav1
.
Convert_Map_string_To_string_T
o_v1_LabelSelector
,
metav1
.
Convert_v1_LabelSelector_To_Map_string_To_string
,
Convert_internalversion_ListOptions_To_v1_ListOptions
,
Convert_v1_ListOptions_To_internalversion_ListOptions
,
...
...
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/conversion.go
View file @
ba95744b
...
...
@@ -33,17 +33,17 @@ func AddConversionFuncs(scheme *runtime.Scheme) error {
return
scheme
.
AddConversionFuncs
(
Convert_v1_TypeMeta_To_v1_TypeMeta
,
Convert_
unversioned_ListMeta_To_unversioned
_ListMeta
,
Convert_
v1_ListMeta_To_v1
_ListMeta
,
Convert_intstr_IntOrString_To_intstr_IntOrString
,
Convert_unversioned_Time_To_unversioned_Time
,
Convert_unversioned_MicroTime_To_unversioned_MicroTime
,
Convert_Pointer_v1_Duration_To_v1_Duration
,
Convert_v1_Duration_To_Pointer_v1_Duration
,
Convert_Slice_string_To_unversioned_Time
,
Convert_Slice_string_To_v1_Time
,
Convert_v1_Time_To_v1_Time
,
Convert_v1_MicroTime_To_v1_MicroTime
,
Convert_resource_Quantity_To_resource_Quantity
,
...
...
@@ -71,8 +71,8 @@ func AddConversionFuncs(scheme *runtime.Scheme) error {
Convert_Pointer_float64_To_float64
,
Convert_float64_To_Pointer_float64
,
Convert_
map_to_unversioned
_LabelSelector
,
Convert_
unversioned_LabelSelector_to_map
,
Convert_
Map_string_To_string_To_v1
_LabelSelector
,
Convert_
v1_LabelSelector_To_Map_string_To_string
,
Convert_Slice_string_To_Slice_int32
,
...
...
@@ -187,7 +187,7 @@ func Convert_v1_TypeMeta_To_v1_TypeMeta(in, out *TypeMeta, s conversion.Scope) e
}
// +k8s:conversion-fn=copy-only
func
Convert_
unversioned_ListMeta_To_unversioned
_ListMeta
(
in
,
out
*
ListMeta
,
s
conversion
.
Scope
)
error
{
func
Convert_
v1_ListMeta_To_v1
_ListMeta
(
in
,
out
*
ListMeta
,
s
conversion
.
Scope
)
error
{
*
out
=
*
in
return
nil
}
...
...
@@ -199,7 +199,14 @@ func Convert_intstr_IntOrString_To_intstr_IntOrString(in, out *intstr.IntOrStrin
}
// +k8s:conversion-fn=copy-only
func
Convert_unversioned_Time_To_unversioned_Time
(
in
*
Time
,
out
*
Time
,
s
conversion
.
Scope
)
error
{
func
Convert_v1_Time_To_v1_Time
(
in
*
Time
,
out
*
Time
,
s
conversion
.
Scope
)
error
{
// Cannot deep copy these, because time.Time has unexported fields.
*
out
=
*
in
return
nil
}
// +k8s:conversion-fn=copy-only
func
Convert_v1_MicroTime_To_v1_MicroTime
(
in
*
MicroTime
,
out
*
MicroTime
,
s
conversion
.
Scope
)
error
{
// Cannot deep copy these, because time.Time has unexported fields.
*
out
=
*
in
return
nil
...
...
@@ -220,14 +227,8 @@ func Convert_v1_Duration_To_Pointer_v1_Duration(in *Duration, out **Duration, s
return
nil
}
func
Convert_unversioned_MicroTime_To_unversioned_MicroTime
(
in
*
MicroTime
,
out
*
MicroTime
,
s
conversion
.
Scope
)
error
{
// Cannot deep copy these, because time.Time has unexported fields.
*
out
=
*
in
return
nil
}
// Convert_Slice_string_To_unversioned_Time allows converting a URL query parameter value
func
Convert_Slice_string_To_unversioned_Time
(
input
*
[]
string
,
out
*
Time
,
s
conversion
.
Scope
)
error
{
// Convert_Slice_string_To_v1_Time allows converting a URL query parameter value
func
Convert_Slice_string_To_v1_Time
(
input
*
[]
string
,
out
*
Time
,
s
conversion
.
Scope
)
error
{
str
:=
""
if
len
(
*
input
)
>
0
{
str
=
(
*
input
)[
0
]
...
...
@@ -275,7 +276,7 @@ func Convert_resource_Quantity_To_resource_Quantity(in *resource.Quantity, out *
return
nil
}
func
Convert_
map_to_unversioned
_LabelSelector
(
in
*
map
[
string
]
string
,
out
*
LabelSelector
,
s
conversion
.
Scope
)
error
{
func
Convert_
Map_string_To_string_To_v1
_LabelSelector
(
in
*
map
[
string
]
string
,
out
*
LabelSelector
,
s
conversion
.
Scope
)
error
{
if
in
==
nil
{
return
nil
}
...
...
@@ -285,7 +286,7 @@ func Convert_map_to_unversioned_LabelSelector(in *map[string]string, out *LabelS
return
nil
}
func
Convert_
unversioned_LabelSelector_to_map
(
in
*
LabelSelector
,
out
*
map
[
string
]
string
,
s
conversion
.
Scope
)
error
{
func
Convert_
v1_LabelSelector_To_Map_string_To_string
(
in
*
LabelSelector
,
out
*
map
[
string
]
string
,
s
conversion
.
Scope
)
error
{
var
err
error
*
out
,
err
=
LabelSelectorAsMap
(
in
)
return
err
...
...
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/conversion_test.go
View file @
ba95744b
...
...
@@ -33,13 +33,13 @@ func TestMapToLabelSelectorRoundTrip(t *testing.T) {
}
for
_
,
in
:=
range
inputs
{
ls
:=
&
v1
.
LabelSelector
{}
if
err
:=
v1
.
Convert_
map_to_unversioned
_LabelSelector
(
&
in
,
ls
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"Convert_
map_to_unversioned
_LabelSelector(%#v): %v"
,
in
,
err
)
if
err
:=
v1
.
Convert_
Map_string_To_string_To_v1
_LabelSelector
(
&
in
,
ls
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"Convert_
Map_string_To_string_To_v1
_LabelSelector(%#v): %v"
,
in
,
err
)
continue
}
out
:=
map
[
string
]
string
{}
if
err
:=
v1
.
Convert_
unversioned_LabelSelector_to_map
(
ls
,
&
out
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"Convert_
unversioned_LabelSelector_to_map
(%#v): %v"
,
ls
,
err
)
if
err
:=
v1
.
Convert_
v1_LabelSelector_To_Map_string_To_string
(
ls
,
&
out
,
nil
);
err
!=
nil
{
t
.
Errorf
(
"Convert_
v1_LabelSelector_To_Map_string_To_string
(%#v): %v"
,
ls
,
err
)
continue
}
if
!
apiequality
.
Semantic
.
DeepEqual
(
in
,
out
)
{
...
...
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/register.go
View file @
ba95744b
...
...
@@ -57,10 +57,10 @@ func AddToGroupVersion(scheme *runtime.Scheme, groupVersion schema.GroupVersion)
&
UpdateOptions
{},
)
utilruntime
.
Must
(
scheme
.
AddConversionFuncs
(
Convert_v
ersioned_Event_t
o_watch_Event
,
Convert_v
ersioned_InternalEvent_to_versioned_
Event
,
Convert_watch_Event_
to_versioned_
Event
,
Convert_v
ersioned_Event_to_versioned
_InternalEvent
,
Convert_v
1_WatchEvent_T
o_watch_Event
,
Convert_v
1_InternalEvent_To_v1_Watch
Event
,
Convert_watch_Event_
To_v1_Watch
Event
,
Convert_v
1_WatchEvent_To_v1
_InternalEvent
,
))
// Register Unversioned types under their own special group
scheme
.
AddUnversionedTypes
(
Unversioned
,
...
...
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/watch.go
View file @
ba95744b
...
...
@@ -39,7 +39,7 @@ type WatchEvent struct {
Object
runtime
.
RawExtension
`json:"object" protobuf:"bytes,2,opt,name=object"`
}
func
Convert_watch_Event_
to_versioned_
Event
(
in
*
watch
.
Event
,
out
*
WatchEvent
,
s
conversion
.
Scope
)
error
{
func
Convert_watch_Event_
To_v1_Watch
Event
(
in
*
watch
.
Event
,
out
*
WatchEvent
,
s
conversion
.
Scope
)
error
{
out
.
Type
=
string
(
in
.
Type
)
switch
t
:=
in
.
Object
.
(
type
)
{
case
*
runtime
.
Unknown
:
...
...
@@ -52,11 +52,11 @@ func Convert_watch_Event_to_versioned_Event(in *watch.Event, out *WatchEvent, s
return
nil
}
func
Convert_v
ersioned_InternalEvent_to_versioned_
Event
(
in
*
InternalEvent
,
out
*
WatchEvent
,
s
conversion
.
Scope
)
error
{
return
Convert_watch_Event_
to_versioned_
Event
((
*
watch
.
Event
)(
in
),
out
,
s
)
func
Convert_v
1_InternalEvent_To_v1_Watch
Event
(
in
*
InternalEvent
,
out
*
WatchEvent
,
s
conversion
.
Scope
)
error
{
return
Convert_watch_Event_
To_v1_Watch
Event
((
*
watch
.
Event
)(
in
),
out
,
s
)
}
func
Convert_v
ersioned_Event_t
o_watch_Event
(
in
*
WatchEvent
,
out
*
watch
.
Event
,
s
conversion
.
Scope
)
error
{
func
Convert_v
1_WatchEvent_T
o_watch_Event
(
in
*
WatchEvent
,
out
*
watch
.
Event
,
s
conversion
.
Scope
)
error
{
out
.
Type
=
watch
.
EventType
(
in
.
Type
)
if
in
.
Object
.
Object
!=
nil
{
out
.
Object
=
in
.
Object
.
Object
...
...
@@ -70,8 +70,8 @@ func Convert_versioned_Event_to_watch_Event(in *WatchEvent, out *watch.Event, s
return
nil
}
func
Convert_v
ersioned_Event_to_versioned
_InternalEvent
(
in
*
WatchEvent
,
out
*
InternalEvent
,
s
conversion
.
Scope
)
error
{
return
Convert_v
ersioned_Event_t
o_watch_Event
(
in
,
(
*
watch
.
Event
)(
out
),
s
)
func
Convert_v
1_WatchEvent_To_v1
_InternalEvent
(
in
*
WatchEvent
,
out
*
InternalEvent
,
s
conversion
.
Scope
)
error
{
return
Convert_v
1_WatchEvent_T
o_watch_Event
(
in
,
(
*
watch
.
Event
)(
out
),
s
)
}
// InternalEvent makes watch.Event versioned
...
...
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
View file @
ba95744b
...
...
@@ -223,7 +223,7 @@ func (s *WatchServer) ServeHTTP(w http.ResponseWriter, req *http.Request) {
// and we get the benefit of using conversion functions which already have to stay in sync
outEvent
:=
&
metav1
.
WatchEvent
{}
*
internalEvent
=
metav1
.
InternalEvent
(
event
)
err
:=
metav1
.
Convert_v
ersioned_InternalEvent_to_versioned_
Event
(
internalEvent
,
outEvent
,
nil
)
err
:=
metav1
.
Convert_v
1_InternalEvent_To_v1_Watch
Event
(
internalEvent
,
outEvent
,
nil
)
if
err
!=
nil
{
utilruntime
.
HandleError
(
fmt
.
Errorf
(
"unable to convert watch object: %v"
,
err
))
// client disconnect.
...
...
@@ -291,7 +291,7 @@ func (s *WatchServer) HandleWS(ws *websocket.Conn) {
// and we get the benefit of using conversion functions which already have to stay in sync
outEvent
:=
&
metav1
.
WatchEvent
{}
*
internalEvent
=
metav1
.
InternalEvent
(
event
)
err
:=
metav1
.
Convert_v
ersioned_InternalEvent_to_versioned_
Event
(
internalEvent
,
outEvent
,
nil
)
err
:=
metav1
.
Convert_v
1_InternalEvent_To_v1_Watch
Event
(
internalEvent
,
outEvent
,
nil
)
if
err
!=
nil
{
utilruntime
.
HandleError
(
fmt
.
Errorf
(
"unable to convert watch object: %v"
,
err
))
// client disconnect.
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment