Minor fixes in federated controller libraries

This commit is contained in:
Marcin Wielgus 2016-08-07 14:26:02 +02:00
parent ab68ce9676
commit c435647dd7
3 changed files with 7 additions and 2 deletions

View File

@ -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
}

View File

@ -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,

View File

@ -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
}