Method patchNodeWithLabel

pkg/csi/plugins/nodeserver.go:433–482

(node *corev1.Node, labelsToModify common.LabelsToModify)

}

func (ns *nodeServer) patchNodeWithLabel(node *corev1.Node, labelsToModify common.LabelsToModify) error {
	labels := labelsToModify.GetLabels()
	labelValuePair := map[string]interface{}{}

	for _, labelToModify := range labels {
		operationType := labelToModify.GetOperationType()
		labelToModifyKey := labelToModify.GetLabelKey()
		labelToModifyValue := labelToModify.GetLabelValue()

		switch operationType {
		case common.AddLabel, common.UpdateLabel:
			labelValuePair[labelToModifyKey] = labelToModifyValue
		case common.DeleteLabel:
			labelValuePair[labelToModifyKey] = nil
		default:
			err := fmt.Errorf("fail to update the label due to the wrong operation: %s", operationType)
			return err
		}
	}

	metadata := map[string]interface{}{
		"metadata": map[string]interface{}{
			"labels": labelValuePair,
		},
	}

	patchByteData, err := json.Marshal(metadata)
	if err != nil {
		return err
	}
	useNodeAuthorization := ns.nodeAuthorizedClient != nil
	if useNodeAuthorization {
		_, err = ns.nodeAuthorizedClient.CoreV1().Nodes().Patch(context.TODO(), node.Name, types.StrategicMergePatchType, patchByteData, metav1.PatchOptions{})
		if err != nil {
			return err
		}
	} else {
		nodeToPatch := &corev1.Node{
			ObjectMeta: metav1.ObjectMeta{
				Name: node.Name,
			},
		}
		err = ns.client.Patch(context.TODO(), nodeToPatch, client.RawPatch(types.StrategicMergePatchType, patchByteData))
		if err != nil {
			return err
		}
	}

	return nil
}

func checkMountInUse(volumeName string) (bool, error) {
	var inUse bool