Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newNetServer (0.18 sec)

  1. cni/pkg/nodeagent/server.go

    		return nil, fmt.Errorf("error initializing the host rules for health checks: %w", err)
    	}
    
    	podNetns := NewPodNetnsProcFinder(os.DirFS(filepath.Join(pconstants.HostMountsPath, "proc")))
    	netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, podNetns, set)
    
    	// Set some defaults
    	s := &Server{
    		ctx:        ctx,
    		kubeClient: client,
    		isReady:    ready,
    		dataplane: &meshDataplane{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    	podNs                PodNetnsFinder
    	// allow overriding for tests
    	netnsRunner        func(fdable NetnsFd, toRun func() error) error
    	hostsideProbeIPSet ipset.IPSet
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache,
    	iptablesConfigurator *iptables.IptablesConfigurator, podNs PodNetnsFinder,
    	probeSet ipset.IPSet,
    ) *NetServer {
    	return &NetServer{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net_test.go

    	ztunnelServer := &fakeZtunnel{}
    
    	fakeIPSetDeps := ipset.FakeNLDeps()
    	set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps}
    	netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs()), set)
    
    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
Back to top