Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newCNIClient (0.36 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
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. 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)
  3. 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