Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
Back to top