- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Walls (0.14 sec)
-
cni/README.md
- it connects to K8S using the kubeconfig and JWT token copied from install-cni to get Pod and Namespace. Since this is a short-running command, each invocation creates a new connection. - If so, calls `istio-iptables` with params to setup pod netns - If ambient, sets up the ambient logic. - `istio-iptables` - sets up iptables to redirect a list of ports to the port envoy will listen
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 12.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
}, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
podIP := netip.MustParseAddr("99.9.9.9") podIPs := []netip.Addr{podIP} expectPodAddedToIPSet(fixture.ipsetDeps, podMeta) err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "faksens") // no calls to ztunnel if iptables failed assert.Equal(t, ztunnelServer.addedPods.Load(), 0) // error is not partial error if errors.Is(err, ErrPartialAdd) { t.Fatal("expected not a partial error") } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT, "-p", "tcp", "-m", "mark", "--mark", inpodTproxyMark, "-j", "ACCEPT", ) // Do not redirect app calls to back itself via Ztunnel when using the endpoint address // e.g. appN => appN by lo iptablesBuilder.AppendVersionedRule("127.0.0.1/32", "::1/128", iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
}, Status: corev1.PodStatus{ PodIP: fakePodIP, }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), valid.Netns,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0)