(namespace, clusterName string)
| 210 | } |
| 211 | |
| 212 | func (c *Controller) removeCluster(namespace, clusterName string) { |
| 213 | key := c.buildClusterKey(namespace, clusterName) |
| 214 | c.mu.Lock() |
| 215 | if cluster, ok := c.clusters[key]; ok { |
| 216 | cluster.Close() |
| 217 | delete(c.clusters, key) |
| 218 | } |
| 219 | c.mu.Unlock() |
| 220 | } |
| 221 | |
| 222 | func (c *Controller) updateCluster(namespace, clusterName string) { |
| 223 | key := c.buildClusterKey(namespace, clusterName) |