Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newPodNetnsCache (0.2 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)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 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{},
    	}
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    	}
    
    	log.Debug("creating ipsets in the node netns")
    	set, err := createHostsideProbeIpset()
    	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)
    	}
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 01:42:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	iptablesConfigurator *iptables.IptablesConfigurator
    	nlDeps               *fakeIptablesDeps
    	ipsetDeps            *ipset.MockedIpsetDeps
    }
    
    func getTestFixure(ctx context.Context) netTestFixture {
    	podNsMap := newPodNetnsCache(openNsTestOverride)
    	nlDeps := &fakeIptablesDeps{}
    	iptablesConfigurator, _ := iptables.NewIptablesConfigurator(nil, &dependencies.DependenciesStub{}, nlDeps)
    
    	ztunnelServer := &fakeZtunnel{}
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 14.3K bytes
    - Viewed (0)
Back to top