(prev, obj interface{})
| 421 | } |
| 422 | |
| 423 | func (c *Controller) postgresTeamUpdate(prev, obj interface{}) { |
| 424 | pgTeam, ok := obj.(*acidv1.PostgresTeam) |
| 425 | if !ok { |
| 426 | c.logger.Errorf("could not cast to PostgresTeam spec") |
| 427 | return |
| 428 | } |
| 429 | c.logger.Debugf("PostgreTeam %q updated. Reloading postgres team CRDs and overwriting cached map", pgTeam.Name) |
| 430 | c.loadPostgresTeams() |
| 431 | } |
| 432 | |
| 433 | func (c *Controller) podClusterName(pod *v1.Pod) spec.NamespacedName { |
| 434 | if name, ok := pod.Labels[c.opConfig.ClusterNameLabel]; ok { |
nothing calls this directly
no test coverage detected