- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getFakeDP (0.13 sec)
-
cni/pkg/nodeagent/informers_test.go
wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, mock.IsType(pod), util.GetPodIPsIfPresent(pod), "", ).Return(nil) server := getFakeDP(fs, client.Kube()) handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 22.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, mock.IsType(pod), util.GetPodIPsIfPresent(pod), valid.Netns, ).Return(nil) dpServer := getFakeDP(fs, client.Kube()) handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 7.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
return &meshDataplane{ kubeClient: fakeClient, netServer: fs, hostsideProbeIPSet: fakeSet, } } func getFakeDP(fs *fakeServer, fakeClient kubernetes.Interface) *meshDataplane { fakeIPSetDeps := ipset.FakeNLDeps() fakeIPSetDeps.On("addIP", mock.Anything, mock.Anything, mock.Anything, mock.Anything,
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 18.7K bytes - Viewed (0)