(stopCh <-chan struct{}, wg *sync.WaitGroup)
| 478 | } |
| 479 | |
| 480 | func (c *Controller) runPostgresTeamInformer(stopCh <-chan struct{}, wg *sync.WaitGroup) { |
| 481 | defer wg.Done() |
| 482 | |
| 483 | c.postgresTeamInformer.Run(stopCh) |
| 484 | } |
| 485 | |
| 486 | func queueClusterKey(eventType EventType, uid types.UID) string { |
| 487 | return fmt.Sprintf("%s-%s", eventType, uid) |