From c435647dd753d2331b5d0a19a4d196ab1ad9d5f6 Mon Sep 17 00:00:00 2001 From: Marcin Wielgus Date: Sun, 7 Aug 2016 14:26:02 +0200 Subject: [PATCH] Minor fixes in federated controller libraries --- .../pkg/federation-controller/util/delaying_deliverer.go | 5 +++++ .../pkg/federation-controller/util/federated_informer.go | 2 +- .../federation-controller/util/federated_informer_test.go | 2 +- 3 files changed, 7 insertions(+), 2 deletions(-) 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 }