github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 21:17:23 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #97078 from srm09/add-context-to-cordon-update

Browse Source 
Passes a context to the drain helper object
This commit is contained in:
Kubernetes Prow Robot 2021-01-21 12:01:03 -08:00 committed by GitHub
commit 2efd293658
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
staging/src/k8s.io/kubectl/pkg/drain/cordon.go
View File

@ -73,6 +73,12 @@ func (c *CordonHelper) UpdateIfRequired(desired bool) bool {
// JSON, or if either patch or update calls fail; it will also return a second error // JSON, or if either patch or update calls fail; it will also return a second error
// whenever creating a patch has failed // whenever creating a patch has failed
func (c *CordonHelper) PatchOrReplace(clientset kubernetes.Interface, serverDryRun bool) (error, error) { func (c *CordonHelper) PatchOrReplace(clientset kubernetes.Interface, serverDryRun bool) (error, error) {
return c.PatchOrReplaceWithContext(context.TODO(), clientset, serverDryRun)
}
// PatchOrReplaceWithContext provides the option to pass a custom context while updating
// the node status
func (c *CordonHelper) PatchOrReplaceWithContext(clientCtx context.Context, clientset kubernetes.Interface, serverDryRun bool) (error, error) {
client := clientset.CoreV1().Nodes() client := clientset.CoreV1().Nodes()
oldData, err := json.Marshal(c.node) oldData, err := json.Marshal(c.node)
@ -93,13 +99,13 @@ func (c *CordonHelper) PatchOrReplace(clientset kubernetes.Interface, serverDryR
if serverDryRun { if serverDryRun {
patchOptions.DryRun = []string{metav1.DryRunAll} patchOptions.DryRun = []string{metav1.DryRunAll}
} }
_, err = client.Patch(context.TODO(), c.node.Name, types.StrategicMergePatchType, patchBytes, patchOptions) _, err = client.Patch(clientCtx, c.node.Name, types.StrategicMergePatchType, patchBytes, patchOptions)
} else { } else {
updateOptions := metav1.UpdateOptions{} updateOptions := metav1.UpdateOptions{}
if serverDryRun { if serverDryRun {
updateOptions.DryRun = []string{metav1.DryRunAll} updateOptions.DryRun = []string{metav1.DryRunAll}
} }
_, err = client.Update(context.TODO(), c.node, updateOptions) _, err = client.Update(clientCtx, c.node, updateOptions)
} }
return err, patchErr return err, patchErr
} }

2
staging/src/k8s.io/kubectl/pkg/drain/default.go
View File

@ -57,7 +57,7 @@ func RunCordonOrUncordon(drainer *Helper, node *corev1.Node, desired bool) error
return nil return nil
} }
err, patchErr := c.PatchOrReplace(drainer.Client, false) err, patchErr := c.PatchOrReplaceWithContext(drainer.Ctx, drainer.Client, false)
if err != nil { if err != nil {
if patchErr != nil { if patchErr != nil {
return fmt.Errorf("cordon error: %s; merge patch error: %s", err.Error(), patchErr.Error()) return fmt.Errorf("cordon error: %s; merge patch error: %s", err.Error(), patchErr.Error())