- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Pod (0.12 sec)
-
cni/pkg/plugin/plugin_test.go
} func TestCmdAddTwoContainersWithLabel(t *testing.T) { pod, ns := buildFakePodAndNSForClient() pod.Spec.Containers[0].Name = "mockContainer" pod.Spec.Containers[1].Name = "istio-proxy" pod.ObjectMeta.Annotations[label.SidecarInject.Name] = "false" testDoAddRun(t, buildMockConf(true, ""), testNSName, pod, ns) } func TestCmdAddTwoContainers(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(4)) waitForMockCalls() assertPodNotAnnotated(t, client, pod) // patch a test label to emulate a POD update event _, err = client.Kube().CoreV1().Pods(pod.Namespace).Patch(ctx, pod.Name, types.MergePatchType, []byte(`{"metadata":{"labels":{"test":"update"}}}`), metav1.PatchOptions{})
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) -
istioctl/pkg/util/ambient/util.go
isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok { return v == "ztunnel" } return isZtunnel }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band // iptables rules within a pod context into `legacy` tables, but your host context preferred // `nft`, we would still inject our rules in-pod into nft tables, which is a bit wonky. //
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
valid := CNIPluginAddEvent{ Netns: "/var/netns/foo", PodName: "pod-bingo", PodNamespace: "funkyns", IPs: []IPConfig{{ Address: *addr, }}, } setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod-bingo", Namespace: "funkyns", }, Spec: corev1.PodSpec{
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) -
istioctl/pkg/injector/injector-list_test.go
) func Test_extractRevisionFromPod(t *testing.T) { cases := []struct { name string pod *corev1.Pod expectedRevision string }{ { name: "no rev", pod: &corev1.Pod{}, expectedRevision: "", }, { name: "has rev annotation", pod: &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Annotations: map[string]string{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Long: "Retrieve information about logging levels of the Ztunnel instance in the specified pod, and update optionally.", Example: ` # Retrieve information about logging levels from all Ztunnel pods istioctl x ztunnel-config log # Update levels of the all loggers for a specific Ztunnel pod istioctl x ztunnel-config log <pod-name[.namespace]> --level off
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
func (s *InformerHandlers) GetAmbientPods() []*corev1.Pod { var pods []*corev1.Pod for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) { ns := s.namespaces.Get(pod.Namespace, "") if ns == nil { log.Warnf("failed to find namespace %s for pod %s", pod.Namespace, pod.Name) } if !util.IsZtunnelPod(s.systemNamespace, pod) && util.PodRedirectionEnabled(ns, pod) { pods = append(pods, pod) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/util/podutil_test.go
pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: "derp", }, Status: corev1.PodStatus{ PodIP: "2.2.2.2", PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}}, }, } podIPs := GetPodIPsIfPresent(pod) assert.Equal(t, len(podIPs), 2) } func TestGetPodIPsIfNoPodIPPresent(t *testing.T) { pod := &corev1.Pod{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/util/podutil.go
if podHasSidecar(pod) { // Ztunnel and sidecar for a single pod is currently not supported; opt out. return false } if pod.GetLabels()[constants.DataplaneModeLabel] == constants.DataplaneModeNone { // Pod explicitly asked to not have ambient redirection enabled return false } return true } func podHasSidecar(pod *corev1.Pod) bool { if _, f := pod.GetAnnotations()[annotation.SidecarStatus.Name]; f { return true }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0)