Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 69 for podIPs (0.15 sec)

  1. cni/pkg/nodeagent/server_test.go

    	podIP := netip.MustParseAddr("99.9.9.1")
    	podIPs := []netip.Addr{podIP}
    
    	server := &fakeServer{}
    	server.On("AddPodToMesh",
    		fakeCtx,
    		pod,
    		podIPs,
    		"",
    	).Return(nil)
    
    	server.Start(fakeCtx)
    	m := meshDataplane{
    		kubeClient: fakeClientSet,
    		netServer:  server,
    	}
    
    	err := m.AddPodToMesh(fakeCtx, pod, podIPs, "")
    	assert.NoError(t, err)
    
    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)
  2. cni/pkg/util/podutil_test.go

    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 0)
    }
    
    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)
  3. cni/pkg/util/podutil.go

    	var podIPs []netip.Addr
    	if len(pod.Status.PodIPs) != 0 {
    		for _, pip := range pod.Status.PodIPs {
    			ip := netip.MustParseAddr(pip.IP)
    			podIPs = append(podIPs, ip)
    		}
    	} else if len(pod.Status.PodIP) != 0 {
    		ip := netip.MustParseAddr(pod.Status.PodIP)
    		podIPs = append(podIPs, ip)
    	}
    	return podIPs
    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)
  4. cni/pkg/nodeagent/informers.go

    	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)
    		}
    	}
    	return pods
    }
    
    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)
  5. cni/pkg/nodeagent/server.go

    	return s.netServer.ConstructInitialSnapshot(ambientPods)
    }
    
    func (s *meshDataplane) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
    	var retErr error
    	err := s.netServer.AddPodToMesh(ctx, pod, podIPs, netNs)
    	if err != nil {
    		log.Errorf("failed to add pod to ztunnel: %v", err)
    		if !errors.Is(err, ErrPartialAdd) {
    			return err
    		}
    		retErr = err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/cni-watcher.go

    	var podIps []netip.Addr
    	for _, configuredPodIPs := range addCmd.IPs {
    		// net.ip is implicitly convertible to netip as slice
    		ip, _ := netip.AddrFromSlice(configuredPodIPs.Address.IP)
    		// We ignore the mask of the IPNet - it's fine if the IPNet defines
    		// a block grant of addresses, we just need one for checking routes.
    		podIps = append(podIps, ip)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  7. istioctl/pkg/dashboard/dashboard_test.go

    			ExpectedOutput: "Error: no pods found with selector app=kiali\n",
    			WantException:  true,
    		},
    		{ // case 9
    			Args:           strings.Split("prometheus --browser=false", " "),
    			ExpectedOutput: "Error: no pods found with selector app.kubernetes.io/name=prometheus\n",
    			WantException:  true,
    		},
    		{ // case 10
    			Args:           strings.Split("zipkin --browser=false", " "),
    			ExpectedOutput: "Error: no pods found with selector app=zipkin\n",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Nov 21 01:17:24 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/revision.go

    	Tag      string `json:"tag,omitempty"`
    }
    
    // NsInfo represents namespace related information like pods running there.
    // It is used to display data and is exposed for integration tests.
    type NsInfo struct {
    	Name string             `json:"name,omitempty"`
    	Pods []*PodFilteredInfo `json:"pods,omitempty"`
    }
    
    // RevisionDescription is used to display revision related information.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Jan 28 13:16:05 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/node/v1beta1/generated.proto

      // +optional
      optional k8s.io.apimachinery.pkg.apis.meta.v1.ObjectMeta metadata = 1;
    
      // handler specifies the underlying runtime and configuration that the CRI
      // implementation will use to handle pods of this class. The possible values
      // are specific to the node & CRI configuration.  It is assumed that all
      // handlers are available on every node, and handlers of the same name are
      // equivalent on every node.
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/scheduling/v1beta1/generated.proto

      // value represents the integer value of this priority class. This is the actual priority that pods
      // receive when they have the name of this class in their pod spec.
      optional int32 value = 2;
    
      // globalDefault specifies whether this PriorityClass should be considered as
      // the default priority for pods that do not have any priority class.
      // Only one PriorityClass can be marked as `globalDefault`. However, if more than
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 2.9K bytes
    - Viewed (0)
Back to top