mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-29 06:27:05 +00:00
Add error return for the Marshal object invocation.
Add error return for the Marshal object invocation.
This commit is contained in:
parent
3900e36d62
commit
65c28eb64f
@ -631,6 +631,9 @@ func (o *DrainOptions) RunCordonOrUncordon(desired bool) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
oldData, err := json.Marshal(obj)
|
oldData, err := json.Marshal(obj)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
node, ok := obj.(*corev1.Node)
|
node, ok := obj.(*corev1.Node)
|
||||||
if !ok {
|
if !ok {
|
||||||
return fmt.Errorf("unexpected Type%T, expected Node", obj)
|
return fmt.Errorf("unexpected Type%T, expected Node", obj)
|
||||||
@ -642,6 +645,9 @@ func (o *DrainOptions) RunCordonOrUncordon(desired bool) error {
|
|||||||
helper := resource.NewHelper(o.restClient, o.nodeInfo.Mapping)
|
helper := resource.NewHelper(o.restClient, o.nodeInfo.Mapping)
|
||||||
node.Spec.Unschedulable = desired
|
node.Spec.Unschedulable = desired
|
||||||
newData, err := json.Marshal(obj)
|
newData, err := json.Marshal(obj)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, obj)
|
patchBytes, err := strategicpatch.CreateTwoWayMergePatch(oldData, newData, obj)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
Loading…
Reference in New Issue
Block a user