Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newPodNetnsCache (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top