- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newNetServer (0.18 sec)
-
cni/pkg/nodeagent/net.go
podNs PodNetnsFinder // allow overriding for tests netnsRunner func(fdable NetnsFd, toRun func() error) error } var _ MeshDataplane = &NetServer{} func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, podIptables *iptables.IptablesConfigurator, podNs PodNetnsFinder) *NetServer { return &NetServer{ ztunnelServer: ztunnelServer, currentPodSnapshot: podNsMap,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
iptablesConfigurator, _, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, &dependencies.DependenciesStub{}, nlDeps) ztunnelServer := &fakeZtunnel{} netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs())) netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error { return toRun() } netServer.Start(ctx)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jul 25 16:13:38 UTC 2024 - 10.7K bytes - Viewed (0) -
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, podIptables, podNetns) // Set some defaults s := &Server{ ctx: ctx, kubeClient: client, isReady: ready, dataplane: &meshDataplane{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0)