mirrors/kube-router
1
0
Fork 0
mirror of https://github.com/cloudnativelabs/kube-router.git synced 2025-10-05 23:11:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix unit test failure due to switch of listing node API objects from (#869)

Browse Source 
API server to cached informer. Modify test to use informer
This commit is contained in:
Murali Reddy 2020-04-06 18:58:31 +05:30 committed by GitHub
parent d838253795
commit 2c4911b9a9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/controllers/routing/network_routes_controller_test.go
View File

@ -1294,9 +1294,11 @@ func Test_syncInternalPeers(t *testing.T) {
}
defer testcase.nrc.bgpServer.Stop()
startInformersForRoutes(testcase.nrc, testcase.nrc.clientset)
if err = createNodes(testcase.nrc.clientset, testcase.existingNodes); err != nil {
t.Errorf("failed to create existing nodes: %v", err)
}
waitForListerWithTimeout(testcase.nrc.nodeLister, time.Second*10, t)
testcase.nrc.syncInternalPeers()
@ -2486,12 +2488,14 @@ func startInformersForRoutes(nrc *NetworkRoutingController, clientset kubernetes
informerFactory := informers.NewSharedInformerFactory(clientset, 0)
svcInformer := informerFactory.Core().V1().Services().Informer()
epInformer := informerFactory.Core().V1().Endpoints().Informer()
nodeInformer := informerFactory.Core().V1().Nodes().Informer()
go informerFactory.Start(nil)
informerFactory.WaitForCacheSync(nil)
nrc.svcLister = svcInformer.GetIndexer()
nrc.epLister = epInformer.GetIndexer()
nrc.nodeLister = nodeInformer.GetIndexer()
}
func waitForListerWithTimeout(lister cache.Indexer, timeout time.Duration, t *testing.T) {