Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for podToWorkload (0.07 sec)

  1. cni/pkg/nodeagent/pod_cache_test.go

    	ns := newFakeNsInode(inc(), 1)
    	wl := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    ns,
    	}
    	netns1 := p.UpsertPodCacheWithNetns(string(pod.UID), wl)
    	if !reflect.DeepEqual(netns1, ns) {
    		t.Fatalf("Expected the same Netns for the same uid, got %v and %v", netns1, ns)
    	}
    
    	ns2 := newFakeNsInode(inc(), 1)
    	wl2 := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    ns2,
    	}
    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

    	}
    }
    
    func (p *podNetnsCache) UpsertPodCache(pod *corev1.Pod, nspath string) (Netns, error) {
    	newnetns, err := p.openNetns(nspath)
    	if err != nil {
    		return nil, err
    	}
    	wl := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    newnetns,
    	}
    	return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil
    }
    
    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/ztunnelserver_test.go

    	ztunClient *net.UnixConn
    	ztunServer *ztunnelServer
    	uid        string
    } {
    	pods := &fakePodCache{}
    
    	pod, ns := podAndNetns()
    	workload := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    ns,
    	}
    	pods.pods = map[string]WorkloadInfo{
    		string(pod.UID): workload,
    	}
    	ret := connectWithPods(ctx, pods)
    
    	return struct {
    		ztunClient *net.UnixConn
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top