- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for uid (0.4 sec)
-
cni/pkg/nodeagent/pod_cache.go
} return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil } // Update the cache with the given Netns. If there is already a Netns for the given uid, we return it, and close the one provided. func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock() defer p.mu.Unlock() if existing := p.currentPodCache[uid]; existing.Netns != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
n := NewPodNetnsProcFinder(fakeFs()) pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "bar", UID: types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"), }} podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{ pod.UID: pod, }) if err != nil { panic(err) } defer podUIDNetns.Close() if len(podUIDNetns) == 0 { t.Fatal("expected to find pod netns")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
"istio.io/istio/pkg/test/util/assert" ) func TestMeshDataplaneAddsAnnotationOnAdd(t *testing.T) { pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", UID: types.UID("test"), }, } fakeCtx := context.Background() fakeClientSet := fake.NewSimpleClientset(pod) podIP := netip.MustParseAddr("99.9.9.1") podIPs := []netip.Addr{podIP} server := &fakeServer{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
// (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4) func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil { return "", err } return kubeSystem.UID, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Sep 02 03:11:58 GMT 2022 - 1.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("name-%d", id), UID: types.UID(fmt.Sprintf("uid-%d", id)), }, Spec: v1.PodSpec{}, Status: v1.PodStatus{}, } return pod, newFakeNs(devNull.Fd()) } func connect(ctx context.Context) struct { ztunClient *net.UnixConn ztunServer *ztunnelServer uid string } { pods := &fakePodCache{} pod, ns := podAndNetns()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}} ns := newFakeNs(inc()) wl := WorkloadInfo{ Workload: podToWorkload(pod), Netns: ns, } netns1 := p.UpsertPodCacheWithNetns(string(pod.UID), wl) netnsTaken := p.Take(string(pod.UID)) if netns1 != netnsTaken { t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns1, ns) } if nil != p.Take(string(pod.UID)) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
cni/pkg/plugin/plugin_dryrun_test.go
}, { name: "custom-uid", annotations: map[string]string{annotation.SidecarStatus.Name: "true"}, customUID: &customUID, customGID: &customGID, golden: filepath.Join(env.IstioSrc, "cni/pkg/plugin/testdata/custom-uid.txt.golden"), }, { name: "custom-uid-zero", annotations: map[string]string{annotation.SidecarStatus.Name: "true"},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 8.4K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
type fakeZtunnel struct { deletedPods atomic.Int32 addedPods atomic.Int32 addError error } func (f *fakeZtunnel) Run(ctx context.Context) { } func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error { f.deletedPods.Add(1) return nil } func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error { f.addedPods.Add(1) return f.addError }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0)