Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newCNIClient (0.15 sec)

  1. cni/pkg/plugin/plugin.go

    			prevResult := conf.PrevResult.(*cniv1.Result)
    			prevResIps = prevResult.IPs
    		}
    
    		// Only send event if this pod "would be" an ambient-watched pod - otherwise skip
    		if podIsAmbient {
    			cniClient := newCNIClient(conf.CNIEventAddress, 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)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  2. cni/pkg/plugin/plugin_test.go

    // returns the test server URL and a dispose func for the test server
    func setupCNIEventClientWithMockServer(serverErr bool) (string, func() bool) {
    	cniAddServerCalled := false
    	// replace the global CNI client with mock
    	newCNIClient = func(address, path string) CNIEventClient {
    		c := http.DefaultClient
    
    		eventC := CNIEventClient{
    			client: c,
    			url:    address + path,
    		}
    		return eventC
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 17.5K bytes
    - Viewed (0)
Back to top