Merge pull request #1205 from aledbf/fix-initial-sync
Add initial sync of secrets
This commit is contained in:
commit
864fc1cefc
1 changed files with 8 additions and 0 deletions
|
@ -1298,6 +1298,14 @@ func (ic GenericController) Start() {
|
||||||
runtime.HandleError(fmt.Errorf("Timed out waiting for caches to sync"))
|
runtime.HandleError(fmt.Errorf("Timed out waiting for caches to sync"))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// initial sync of secrets to avoid unnecessary reloads
|
||||||
|
for _, key := range ic.ingLister.ListKeys() {
|
||||||
|
if obj, exists, _ := ic.ingLister.GetByKey(key); exists {
|
||||||
|
ing := obj.(*extensions.Ingress)
|
||||||
|
ic.readSecrets(ing)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
go ic.syncQueue.Run(time.Second, ic.stopCh)
|
go ic.syncQueue.Run(time.Second, ic.stopCh)
|
||||||
|
|
||||||
if ic.syncStatus != nil {
|
if ic.syncStatus != nil {
|
||||||
|
|
Loading…
Reference in a new issue