(cluster *store.Cluster)
| 319 | } |
| 320 | |
| 321 | func (c *ClusterChecker) updateCluster(cluster *store.Cluster) { |
| 322 | c.clusterMu.Lock() |
| 323 | c.cluster = cluster |
| 324 | c.clusterMu.Unlock() |
| 325 | } |
| 326 | |
| 327 | func (c *ClusterChecker) tryUpdateMigrationStatus(ctx context.Context, clonedCluster *store.Cluster) { |
| 328 | log := logger.Get().With( |
no outgoing calls
no test coverage detected