drop unnecessary code, use informer fork

Author: fabianvf

pkg/kcp/controller.go

@@ -195,9 +195,8 @@ func (s *sharedIndexInformer) Run(stopCh <-chan struct{}) {
 		s.startedLock.Lock()
 		defer s.startedLock.Unlock()
 
-		s.controller = New(cfg)
-		// TODO(KCP)
-		s.controller.(*controller).clock = s.clock
+		s.controller = cache.New(cfg)
+
 		s.started = true
 	}()
 
@@ -627,3 +626,47 @@ func (p *processorListener) setResyncPeriod(resyncPeriod time.Duration) {
 
 	p.resyncPeriod = resyncPeriod
 }
+
+// Multiplexes updates in the form of a list of Deltas into a Store, and informs
+// a given handler of events OnUpdate, OnAdd, OnDelete
+// taken from k8s.io/client-go/tools/cache/controller.go
+func processDeltas(
+	// Object which receives event notifications from the given deltas
+	handler cache.ResourceEventHandler,
+	clientState cache.Store,
+	transformer cache.TransformFunc,
+	deltas cache.Deltas,
+) error {
+	// from oldest to newest
+	for _, d := range deltas {
+		obj := d.Object
+		if transformer != nil {
+			var err error
+			obj, err = transformer(obj)
+			if err != nil {
+				return err
+			}
+		}
+
+		switch d.Type {
+		case cache.Sync, cache.Replaced, cache.Added, cache.Updated:
+			if old, exists, err := clientState.Get(obj); err == nil && exists {
+				if err := clientState.Update(obj); err != nil {
+					return err
+				}
+				handler.OnUpdate(old, obj)
+			} else {
+				if err := clientState.Add(obj); err != nil {
+					return err
+				}
+				handler.OnAdd(obj)
+			}
+		case cache.Deleted:
+			if err := clientState.Delete(obj); err != nil {
+				return err
+			}
+			handler.OnDelete(obj)
+		}
+	}
+	return nil
+}

pkg/kcp/informers.go

@@ -57,7 +57,6 @@ func NewClusterAwareManager(cfg *rest.Config, options ctrl.Options) (manager.Man
 func NewClusterAwareCache(config *rest.Config, opts cache.Options) (cache.Cache, error) {
 	c := rest.CopyConfig(config)
 	c.Host += "/clusters/*"
-	// opts.NewInformerFunc = NewClusterAwareSharedIndexInformerFunc(kcpcache.ClusterAwareKeyFunc)
 	opts.NewInformerFunc = NewSharedIndexInformer
 
 	opts.Indexers = k8scache.Indexers{