()
| 401 | } |
| 402 | |
| 403 | func (c *Controller) loadPostgresTeams() { |
| 404 | pgTeams, err := c.KubeClient.PostgresTeamsGetter.PostgresTeams(c.opConfig.WatchedNamespace).List(context.TODO(), metav1.ListOptions{}) |
| 405 | if err != nil { |
| 406 | c.logger.Errorf("could not list postgres team objects: %v", err) |
| 407 | } |
| 408 | |
| 409 | c.pgTeamMap.Load(pgTeams) |
| 410 | c.logger.Debugf("Internal Postgres Team Cache: %#v", c.pgTeamMap) |
| 411 | } |
| 412 | |
| 413 | func (c *Controller) postgresTeamAdd(obj interface{}) { |
| 414 | pgTeam, ok := obj.(*acidv1.PostgresTeam) |
no test coverage detected