- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewPodNetnsProcFinder (0.33 sec)
-
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"), }}
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 17:36:49 UTC 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
ztunnelServer := &fakeZtunnel{} netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs())) netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error { return toRun() } netServer.Start(ctx) return netTestFixture{ netServer: netServer,
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
if err := hostIptables.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, podIptables, podNetns) // Set some defaults s := &Server{ ctx: ctx,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0)