■ ■ ■ ■ ■ ■
pkg/router/proxy/kubernetes.go
| skipped 96 lines |
97 | 97 | | logStr = clusterName + "-" + askParam |
98 | 98 | | go kolog.Save(operator, constant.DELETE_CLUSTER_STORAGE_CLASS, logStr) |
99 | 99 | | } else { |
100 | | - | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
101 | | - | if isMap { |
102 | | - | _, hasValue := metadata["name"] |
103 | | - | if hasValue { |
104 | | - | _, isString := metadata["name"].(string) |
105 | | - | if isString { |
106 | | - | logStr = clusterName + "-" + metadata["name"].(string) |
107 | | - | go kolog.Save(operator, constant.CREATE_CLUSTER_STORAGE_CLASS, logStr) |
| 100 | + | if _, ok := valueMap["metadata"]; ok { |
| 101 | + | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
| 102 | + | if isMap { |
| 103 | + | _, hasValue := metadata["name"] |
| 104 | + | if hasValue { |
| 105 | + | _, isString := metadata["name"].(string) |
| 106 | + | if isString { |
| 107 | + | logStr = clusterName + "-" + metadata["name"].(string) |
| 108 | + | go kolog.Save(operator, constant.CREATE_CLUSTER_STORAGE_CLASS, logStr) |
| 109 | + | } |
108 | 110 | | } |
109 | 111 | | } |
110 | 112 | | } |
| skipped 3 lines |
114 | 116 | | logStr = clusterName + "-" + askParam |
115 | 117 | | go kolog.Save(operator, constant.DELETE_CLUSTER_NAMESPACE, logStr) |
116 | 118 | | } else { |
117 | | - | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
118 | | - | if isMap { |
119 | | - | _, hasValue := metadata["name"] |
120 | | - | if hasValue { |
121 | | - | _, isString := metadata["name"].(string) |
122 | | - | if isString { |
123 | | - | logStr = clusterName + "-" + metadata["name"].(string) |
124 | | - | go kolog.Save(operator, constant.CREATE_CLUSTER_NAMESPACE, logStr) |
| 119 | + | if _, ok := valueMap["metadata"]; ok { |
| 120 | + | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
| 121 | + | if isMap { |
| 122 | + | _, hasValue := metadata["name"] |
| 123 | + | if hasValue { |
| 124 | + | _, isString := metadata["name"].(string) |
| 125 | + | if isString { |
| 126 | + | logStr = clusterName + "-" + metadata["name"].(string) |
| 127 | + | go kolog.Save(operator, constant.CREATE_CLUSTER_NAMESPACE, logStr) |
| 128 | + | } |
125 | 129 | | } |
126 | 130 | | } |
127 | 131 | | } |
| skipped 3 lines |
131 | 135 | | logStr = clusterName + "-" + askParam |
132 | 136 | | go kolog.Save(operator, constant.DELETE_CLUSTER_PVC, logStr) |
133 | 137 | | } else { |
134 | | - | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
135 | | - | if isMap { |
136 | | - | _, hasValue := metadata["name"] |
137 | | - | if hasValue { |
138 | | - | _, isString := metadata["name"].(string) |
139 | | - | if isString { |
140 | | - | logStr = clusterName + "-" + metadata["name"].(string) |
141 | | - | go kolog.Save(operator, constant.CREATE_CLUSTER_PVC, logStr) |
| 138 | + | if _, ok := valueMap["metadata"]; ok { |
| 139 | + | metadata, isMap := valueMap["metadata"].(map[string]interface{}) |
| 140 | + | if isMap { |
| 141 | + | _, hasValue := metadata["name"] |
| 142 | + | if hasValue { |
| 143 | + | _, isString := metadata["name"].(string) |
| 144 | + | if isString { |
| 145 | + | logStr = clusterName + "-" + metadata["name"].(string) |
| 146 | + | go kolog.Save(operator, constant.CREATE_CLUSTER_PVC, logStr) |
| 147 | + | } |
142 | 148 | | } |
143 | 149 | | } |
144 | 150 | | } |
| skipped 25 lines |