Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for PodIP (0.03 sec)

  1. cni/pkg/nodeagent/net_test.go

    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    			PodIP:  "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164",
    			PodIPs: []corev1.PodIP{{IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164"}, {IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"}},
    		}
    	} else {
    		podStatus = corev1.PodStatus{
    			PodIP:  "2.2.2.2",
    			PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}},
    		}
    	}
    
    	return &corev1.Pod{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/informers_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIPs: []corev1.PodIP{},
    			PodIP:  "",
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	fs := &fakeServer{}
    
    	server := getFakeDP(fs, client.Kube())
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. cni/pkg/util/podutil.go

    		return nil
    	}
    	return err
    }
    
    // Get any IPs currently assigned to the Pod.
    //
    // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'),
    // otherwise fallback to 'PodIP'.
    //
    // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish)
    // K8S may not have received the pod IPs yet, and may not report the pod as having any.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server_test.go

    	return wg.done
    }
    
    func expectPodAddedToIPSet(ipsetDeps *ipset.MockedIpsetDeps, podIP netip.Addr, podMeta metav1.ObjectMeta) {
    	ipsetDeps.On("addIP",
    		"foo-v4",
    		podIP,
    		uint8(unix.IPPROTO_TCP),
    		string(podMeta.UID),
    		false,
    	).Return(nil)
    }
    
    func expectPodRemovedFromIPSet(ipsetDeps *ipset.MockedIpsetDeps, podIPs []corev1.PodIP) {
    	for _, ip := range podIPs {
    		ipsetDeps.On("clearEntriesWithIP",
    			"foo-v4",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. cni/pkg/util/podutil_test.go

    			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{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/cni-watcher_test.go

    	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)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. cni/pkg/repair/netns.go

    //
    // Instead, we traverse the procfs. Comments on this method are inline.
    func getPodNetNs(pod *corev1.Pod) (string, error) {
    	parsedPodAddr := net.ParseIP(pod.Status.PodIP)
    	if parsedPodAddr == nil {
    		return "", fmt.Errorf("failed to parse addr: %s", pod.Status.PodIP)
    	}
    
    	fs, err := procfs.NewFS("/host/proc")
    	if err != nil {
    		return "", fmt.Errorf("read procfs: %v", err)
    	}
    	procs, err := fs.AllProcs()
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/informers.go

    			// for the pod. If this is a pod added via informer, the pod should have already gone thru
    			// the CNI plugin chain, and have a PodIP.
    			//
    			// If PodIPs exists, it is preferred, otherwise fallback to PodIP.
    			//
    			// If we get to this point and have a pod that really and truly has no IP in either of those,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/core/v1/generated.proto

      // +optional
      optional string podIP = 6;
    
      // podIPs holds the IP addresses allocated to the pod. If this field is specified, the 0th entry must
      // match the podIP field. Pods may be allocated at most 1 value for each of IPv4 and IPv6. This list
      // is empty if no IPs have been allocated yet.
      // +optional
      // +patchStrategy=merge
      // +patchMergeKey=ip
      repeated PodIP podIPs = 12;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 255.8K bytes
    - Viewed (0)
  10. common/scripts/metallb-native.yaml

              valueFrom:
                fieldRef:
                  fieldPath: status.hostIP
            - name: METALLB_ML_BIND_ADDR
              valueFrom:
                fieldRef:
                  fieldPath: status.podIP
            - name: METALLB_ML_LABELS
              value: app=metallb,component=speaker
            - name: METALLB_ML_SECRET_KEY_PATH
              value: /etc/ml_secret_key
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Feb 23 23:56:31 UTC 2024
    - 63.9K bytes
    - Viewed (0)
Back to top