- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newCNIClient (0.07 sec)
-
cni/pkg/plugin/cnieventclient.go
"net/http" "time" "github.com/containernetworking/cni/pkg/skel" cniv1 "github.com/containernetworking/cni/pkg/types/100" "istio.io/istio/cni/pkg/nodeagent" ) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jul 02 18:48:50 UTC 2024 - 2.7K bytes - Viewed (0) -
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)