- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newPodNetnsCache (0.27 sec)
-
cni/pkg/nodeagent/pod_cache_test.go
i := 0 return func(s string) (NetnsCloser, error) { inode := inodes[i] i++ return newFakeNsInode(inc(), inode), nil } } func TestUpsertPodCache(t *testing.T) { counter.Store(0) p := newPodNetnsCache(openNsTestOverrideWithInodes(1, 1)) pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}} nspath1 := "/path/to/netns/1" nspath2 := "/path/to/netns/2" netns1, err := p.UpsertPodCache(pod, nspath1)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 4.2K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
mu sync.RWMutex } type WorkloadInfo struct { Workload *zdsapi.WorkloadInfo Netns NetnsCloser } var _ PodNetnsCache = &podNetnsCache{} func newPodNetnsCache(openNetns func(nspath string) (NetnsCloser, error)) *podNetnsCache { return &podNetnsCache{ openNetns: openNetns, currentPodCache: map[string]WorkloadInfo{}, } }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.3K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
ztunnelServer *fakeZtunnel iptablesConfigurator *iptables.IptablesConfigurator nlDeps *fakeIptablesDeps } func getTestFixure(ctx context.Context) netTestFixture { podNsMap := newPodNetnsCache(openNsTestOverride) nlDeps := &fakeIptablesDeps{} iptablesConfigurator, _, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, &dependencies.DependenciesStub{}, nlDeps)
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
log.Debug("creating ipsets in the node netns") set, err := createHostsideProbeIpset(cfg.EnableIPv6) if err != nil { return nil, fmt.Errorf("error initializing hostside probe ipset: %w", err) } podNsMap := newPodNetnsCache(openNetnsInRoot(pconstants.HostMountsPath)) ztunnelServer, err := newZtunnelServer(args.ServerSocket, podNsMap) if err != nil { return nil, fmt.Errorf("error initializing the ztunnel server: %w", err) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0)