rancher/norman
1
0
Fork 0
mirror of https://github.com/rancher/norman.git synced 2025-08-01 23:41:24 +00:00
Code Issues Releases Wiki Activity

Fix startup issues

Browse Source
This commit is contained in:
Darren Shepherd 2017-11-28 18:24:53 -07:00
parent 391a96f33d
commit 247d4fe74b
3 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
controller/generic_controller.go
View File

@ -98,13 +98,14 @@ func (g *genericController) sync(ctx context.Context) error {
DeleteFunc: g.queueObject,
})
logrus.Infof("Starting %s Controller", g.name)
logrus.Infof("Syncing %s Controller", g.name)
go g.informer.Run(ctx.Done())
if !cache.WaitForCacheSync(ctx.Done(), g.informer.HasSynced) {
return fmt.Errorf("failed to sync controller %s", g.name)
}
logrus.Infof("Syncing %s Controller Done", g.name)
g.synced = true
return nil

2
controller/starter.go
View File

@ -12,7 +12,7 @@ type Starter interface {
}
func Sync(ctx context.Context, starters ...Starter) error {
eg, ctx := errgroup.WithContext(ctx)
eg, _ := errgroup.WithContext(ctx)
for _, starter := range starters {
func(starter Starter) {
eg.Go(func() error {

4
store/crd/crd_store.go
View File

@ -134,8 +134,8 @@ func (c *Store) AddSchemas(ctx context.Context, schemas ...*types.Schema) error
}
for schema, crd := range schemaStatus {
if crd, ok := ready[crd.Name]; ok {
schemaStatus[schema] = crd
if readyCrd, ok := ready[crd.Name]; ok {
schemaStatus[schema] = readyCrd
} else {
if err := c.waitCRD(ctx, crd.Name, schema, schemaStatus); err != nil {
return err