分享一段确保删除资源的代码模型

柔情只为你懂 2023-06-28 11:25 29阅读 0赞

不仅可用于删除操作，也可用于单次操作失败需要持久进行某操作的情况。

> 有的时候用户点击删除由于某些原因导致没有删除掉，或者有的资源删除pending可能还留在页面（如rancher上偶尔会出现该情况，删应用，删项目等等），一般情况下我们都是调一次删除接口，结果分两种，一种是成功删除，另一种是因某报错未删除资源，为后者时资源仍会留在界面上，用户只能继续多次进行删除操作。这时候这个逻辑就大显神威了，这就可以保证给用户看到的该资源一直是removing状态，即时第一次没删除，那么该协程将继续循环执行删除操作，不需要用户再去手动删除。
> 
> 以下代码模型是看rancher源码时发现的，删除Templates的代码。

## 代码如下 ##

func (m *Manager) deleteTemplates(key string, namespace string) error {
    	templates, err := m.getTemplateMap(key, namespace)
    	if err != nil {
    		return err
    	}
    	tvToDelete := map[string]struct{}{}
    	for _, t := range templates {
    		tvs, err := m.getTemplateVersion(t.Name, namespace)
    		if err != nil {
    			return err
    		}
    		for k := range tvs {
    			tvToDelete[k] = struct{}{}
    		}
    	}
        // 重点是下面
    	go func() {
    		for {
                    // 删除templates 
    			for k := range templates {
    				if err := m.templateClient.DeleteNamespaced(namespace, k, &metav1.DeleteOptions{}); err != nil && !kerrors.IsNotFound(err) {
    					logrus.Warnf("Deleting template %v doesn't succeed. Continue loop", k)
    					continue
    				}
    			}
                     // 删除templateVersion
    			for k := range tvToDelete {
    				if err := m.templateVersionClient.DeleteNamespaced(namespace, k, &metav1.DeleteOptions{}); err != nil && !kerrors.IsNotFound(err) {
    					logrus.Warnf("Deleting templateVersion %v doesn't succeed. Continue loop", k)
    					continue
    				}
    			}
    			break
    		}
    	}()
    	return nil
    }

### 海面时常波涛汹涌，海底却永远宁静。 ###