Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newCNIClient (0.17 sec)

  1. 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
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  2. cni/pkg/plugin/plugin.go

    		}
    		prevResult := conf.PrevResult.(*cniv1.Result)
    
    		// 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, prevResult.IPs, podName, podNamespace); err != nil {
    				log.Errorf("istio-cni cmdAdd failed to signal node Istio CNI agent: %s", err)
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  3. 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 01 22:53:12 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 17.5K bytes
    - Viewed (0)
Back to top