@@ -112,12 +112,13 @@ func createWellKnownKubeAPIServerOperatorResource(ctx context.Context, resourceC
112
112
unstructuredKasOperator , err := resourceClient .Create (ctx , unstructuredKasOperatorManifest , metav1.CreateOptions {})
113
113
o .Expect (err ).NotTo (o .HaveOccurred ())
114
114
115
- kasOperator := unstructuredToKubeAPIServerOperator (unstructuredKasOperator .Object )
116
- kasOperatorFromManifest := unstructuredToKubeAPIServerOperator (unstructuredKasOperatorManifest .Object )
117
- kasOperator .Status = kasOperatorFromManifest .Status
118
- unstructuredKasOperator , err = resourceClient .UpdateStatus (ctx , kubeAPIServerOperatorToUnstructured (kasOperator ), metav1.UpdateOptions {})
115
+ manifestStatus , _ , err := unstructured .NestedMap (unstructuredKasOperatorManifest .Object , "status" )
119
116
o .Expect (err ).NotTo (o .HaveOccurred ())
120
- kasOperator = unstructuredToKubeAPIServerOperator (unstructuredKasOperator .Object )
117
+ err = unstructured .SetNestedMap (unstructuredKasOperator .Object , manifestStatus , "status" )
118
+ o .Expect (err ).NotTo (o .HaveOccurred ())
119
+ unstructuredKasOperator , err = resourceClient .UpdateStatus (ctx , unstructuredKasOperator , metav1.UpdateOptions {})
120
+ o .Expect (err ).NotTo (o .HaveOccurred ())
121
+ kasOperator := unstructuredToKubeAPIServerOperator (unstructuredKasOperator .Object )
121
122
o .Expect (kasOperator .Status .NodeStatuses ).To (o .Equal ([]operatorv1.NodeStatus {
122
123
{NodeName : "master-1" },
123
124
{NodeName : "master-2" },
@@ -200,12 +201,6 @@ func unstructuredToKubeAPIServerOperator(obj map[string]interface{}) *operatorv1
200
201
return ret
201
202
}
202
203
203
- func kubeAPIServerOperatorToUnstructured (kasOperator * operatorv1.KubeAPIServer ) * unstructured.Unstructured {
204
- raw , err := runtime .DefaultUnstructuredConverter .ToUnstructured (kasOperator )
205
- o .Expect (err ).NotTo (o .HaveOccurred ())
206
- return & unstructured.Unstructured {Object : raw }
207
- }
208
-
209
204
func createResourceClient (cfg * rest.Config , gvr schema.GroupVersionResource ) dynamic.ResourceInterface {
210
205
dynamicClient , err := dynamic .NewForConfig (cfg )
211
206
o .Expect (err ).NotTo (o .HaveOccurred ())
0 commit comments