Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for CoreV1 (0.13 sec)

  1. istioctl/pkg/injector/injector-list.go

    func getNamespaces(ctx context.Context, client kube.CLIClient, istioNamespace string) ([]corev1.Namespace, error) {
    	nsList, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{})
    	if err != nil {
    		return []corev1.Namespace{}, err
    	}
    	filtered := filterSystemNamespaces(nsList.Items, istioNamespace)
    	filtered = slices.Filter(filtered, func(namespace corev1.Namespace) bool {
    		return !ambient.InAmbient(&namespace)
    	})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cni/pkg/util/podutil.go

    func PodRedirectionActive(pod *corev1.Pod) bool {
    	return pod.GetAnnotations()[annotation.AmbientRedirection.Name] == constants.AmbientRedirectionEnabled
    }
    
    func podHasSidecar(pod *corev1.Pod) bool {
    	if _, f := pod.GetAnnotations()[annotation.SidecarStatus.Name]; f {
    		return true
    	}
    	return false
    }
    
    func IsZtunnelPod(systemNs string, pod *corev1.Pod) bool {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. istioctl/pkg/util/ambient/util.go

    func InAmbient(obj metav1.Object) bool {
    	if obj == nil {
    		return false
    	}
    	switch t := obj.(type) {
    	case *corev1.Pod:
    		return t.GetAnnotations()[annotation.AmbientRedirection.Name] == constants.AmbientRedirectionEnabled
    	case *corev1.Namespace:
    		if t.GetLabels()["istio-injection"] == "enabled" {
    			return false
    		}
    		if v, ok := t.GetLabels()[label.IoIstioRev.Name]; ok && v != "" {
    			return false
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    				},
    			},
    		},
    		StartupProbe: &corev1.Probe{
    			ProbeHandler: corev1.ProbeHandler{
    				HTTPGet: &corev1.HTTPGetAction{
    					Port: intstr.FromInt(7777),
    				},
    			},
    		},
    	}
    
    	containers := []corev1.Container{app1}
    
    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    			PodIP:  "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. istioctl/pkg/describe/describe_test.go

    							{
    								Name:       "http",
    								Port:       80,
    								TargetPort: intstr.FromInt32(80),
    								Protocol:   corev1.ProtocolTCP,
    							},
    						},
    					},
    					Status: corev1.ServiceStatus{
    						LoadBalancer: corev1.LoadBalancerStatus{Ingress: []corev1.LoadBalancerIngress{
    							{
    								IP: "2.2.2.2",
    							},
    						}},
    					},
    				},
    				&corev1.Service{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  6. 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{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/cni-watcher_test.go

    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: fakePodIP,
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. cni/pkg/util/podutil_test.go

    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 1)
    }
    
    func TestGetPodIPsIfPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. cni/pkg/plugin/plugin_dryrun_test.go

    	if err != nil {
    		t.Fatalf("failed with error: %v", err)
    	}
    }
    
    func buildFakeDryRunPod() *corev1.Pod {
    	app := corev1.Container{Name: "test"}
    	proxy := corev1.Container{Name: "istio-proxy"}
    	validate := corev1.Container{Name: "istio-validate"}
    	fakePod := &corev1.Pod{
    		TypeMeta: metav1.TypeMeta{
    			APIVersion: "core/v1",
    			Kind:       "Pod",
    		},
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Aug 27 16:44:45 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers_test.go

    	defer cancel()
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIPs: []corev1.PodIP{
    				{
    					IP: "11.1.1.12",
    				},
    			},
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top