diff --git a/federation/pkg/federation-controller/util/delaying_deliverer.go b/federation/pkg/federation-controller/util/delaying_deliverer.go index bfd08a2efbd..eea84cc1fb5 100644 --- a/federation/pkg/federation-controller/util/delaying_deliverer.go +++ b/federation/pkg/federation-controller/util/delaying_deliverer.go @@ -153,3 +153,8 @@ func (d *DelayingDeliverer) DeliverAt(key string, value interface{}, deliveryTim func (d *DelayingDeliverer) DeliverAfter(key string, value interface{}, delay time.Duration) { d.DeliverAt(key, value, time.Now().Add(delay)) } + +// Gets target chanel of the deliverer. +func (d *DelayingDeliverer) GetTargetChannel() chan *DelayingDelivererItem { + return d.targetChannel +} diff --git a/federation/pkg/federation-controller/util/federated_informer.go b/federation/pkg/federation-controller/util/federated_informer.go index a1e7db62206..7b94b99d257 100644 --- a/federation/pkg/federation-controller/util/federated_informer.go +++ b/federation/pkg/federation-controller/util/federated_informer.go @@ -116,7 +116,7 @@ type ClusterLifecycleHandlerFuncs struct { func NewFederatedInformer( federationClient federation_release_1_4.Interface, targetInformerFactory TargetInformerFactory, - clusterLifecycle ClusterLifecycleHandlerFuncs) FederatedInformer { + clusterLifecycle *ClusterLifecycleHandlerFuncs) FederatedInformer { federatedInformer := &federatedInformerImpl{ targetInformerFactory: targetInformerFactory, diff --git a/federation/pkg/federation-controller/util/federated_informer_test.go b/federation/pkg/federation-controller/util/federated_informer_test.go index 2fb1cc4295f..267f3e6554c 100644 --- a/federation/pkg/federation-controller/util/federated_informer_test.go +++ b/federation/pkg/federation-controller/util/federated_informer_test.go @@ -105,7 +105,7 @@ func TestFederatedInformer(t *testing.T) { }, } - informer := NewFederatedInformer(fakeClient, targetInformerFactory, lifecycle).(*federatedInformerImpl) + informer := NewFederatedInformer(fakeClient, targetInformerFactory, &lifecycle).(*federatedInformerImpl) informer.clientFactory = func(cluster *federation_api.Cluster) (federation_release_1_4.Interface, error) { return fakeClient, nil }