Wait for controller to initialize

Author: fabianvf

pkg/kcp/informers.go

@@ -43,8 +43,6 @@ func (i *clusterAwareSharedIndexInformer) GetController() cache.Controller {
 
 func (i *clusterAwareSharedIndexInformer) Run(stopCh <-chan struct{}) {
 	go i.delegate.Run(stopCh)
-	// TODO(kcp) this is fragile
-	time.Sleep(10000)
 	// need to update keyfunc in:
 	// [x] i.delegate.indexer.keyFunc
 	// [x] i.delegate.controller.config.Queue.keyFunc
@@ -55,9 +53,17 @@ func (i *clusterAwareSharedIndexInformer) Run(stopCh <-chan struct{}) {
 
 	pointerVal := reflect.ValueOf(i.delegate)
 	val := reflect.Indirect(pointerVal)
-	controllerField := val.FieldByName("controller")
-	ptrToController := unsafe.Pointer(controllerField.UnsafeAddr())
-	controller := reflect.NewAt(controllerField.Type(), ptrToController).Elem().Interface()
+
+	var controllerField reflect.Value
+	var ptrToController unsafe.Pointer
+	var controllerVal reflect.Value
+
+	for ok := true; ok; ok = controllerVal.IsZero() {
+		controllerField = val.FieldByName("controller")
+		ptrToController = unsafe.Pointer(controllerField.UnsafeAddr())
+		controllerVal = reflect.NewAt(controllerField.Type(), ptrToController).Elem()
+	}
+	controller := controllerVal.Interface()
 
 	configval := reflect.Indirect(reflect.ValueOf(controller)).FieldByName("config")
 	ptrToConfig := unsafe.Pointer(configval.UnsafeAddr())