- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newCNIClient (0.07 sec)
-
cni/pkg/plugin/plugin.go
} // Only send event if this pod "would be" an ambient-watched pod - otherwise skip if podIsAmbient { cniEventAddr := filepath.Join(conf.CNIAgentRunDir, constants.CNIEventSocketName) cniClient := newCNIClient(cniEventAddr, constants.CNIAddEventPath) if err = PushCNIEvent(cniClient, args, prevResIps, podName, podNamespace); err != nil { log.Errorf("istio-cni cmdAdd failed to signal node Istio CNI agent: %s", err)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
res.Write([]byte("server not happy")) return } res.WriteHeader(http.StatusOK) res.Write([]byte("server happy")) })) // replace the global CNI client with mock newCNIClient = func(address, path string) CNIEventClient { c := http.DefaultClient eventC := CNIEventClient{ client: c, url: testServer.URL + path, } return eventC }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 17.3K bytes - Viewed (0)