Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewPodNetnsProcFinder (0.44 sec)

  1. cni/pkg/nodeagent/podcgroupns_test.go

    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestWithProcFs(t *testing.T) {
    	n := NewPodNetnsProcFinder(fakeFs())
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"),
    	}}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	if err := iptablesConfigurator.CreateHostRulesForHealthChecks(&HostProbeSNATIP, &HostProbeSNATIPV6); err != nil {
    		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,
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/podcgroupns.go

    		wl.Netns.Close()
    	}
    }
    
    type PodNetnsFinder interface {
    	FindNetnsForPods(filter map[types.UID]*corev1.Pod) (PodToNetns, error)
    }
    
    type PodNetnsProcFinder struct {
    	proc fs.FS
    }
    
    func NewPodNetnsProcFinder(proc fs.FS) *PodNetnsProcFinder {
    	return &PodNetnsProcFinder{proc: proc}
    }
    
    func isNotNumber(r rune) bool {
    	return r < '0' || r > '9'
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  4. 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)
    	return netTestFixture{
    		netServer:            netServer,
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
Back to top