Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 268 for podapi (0.18 sec)

  1. pkg/registry/core/pod/storage/eviction_test.go

    	"k8s.io/apiserver/pkg/registry/rest"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	"k8s.io/client-go/kubernetes/fake"
    	featuregatetesting "k8s.io/component-base/featuregate/testing"
    	podapi "k8s.io/kubernetes/pkg/api/pod"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/apis/policy"
    	"k8s.io/kubernetes/pkg/features"
    )
    
    func TestEviction(t *testing.T) {
    	testcases := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 09:26:37 UTC 2024
    - 40K bytes
    - Viewed (0)
  2. staging/src/k8s.io/client-go/applyconfigurations/core/v1/podip.go

    package v1
    
    // PodIPApplyConfiguration represents an declarative configuration of the PodIP type for use
    // with apply.
    type PodIPApplyConfiguration struct {
    	IP *string `json:"ip,omitempty"`
    }
    
    // PodIPApplyConfiguration constructs an declarative configuration of the PodIP type for use with
    // apply.
    func PodIP() *PodIPApplyConfiguration {
    	return &PodIPApplyConfiguration{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 04 18:31:34 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  3. pkg/apis/core/v1/conversion_test.go

    		}
    		// match v1.PodIPs to core.PodIPs
    		for idx := range input.PodIPs {
    			if v1PodStatus.PodIPs[idx].IP != input.PodIPs[idx].IP {
    				t.Errorf("%v: Convert core.PodStatus to v1.PodStatus failed. Expected v1.PodStatus[%v]=%v but found %v", i, idx, input.PodIPs[idx].IP, v1PodStatus.PodIPs[idx].IP)
    			}
    		}
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 05:34:15 UTC 2023
    - 21.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    			}
    
    			status := kl.generateAPIPodStatus(pod, criStatus, false)
    			if !reflect.DeepEqual(status.PodIPs, tc.podIPs) {
    				t.Fatalf("Expected PodIPs %#v, got %#v", tc.podIPs, status.PodIPs)
    			}
    			if status.PodIP != status.PodIPs[0].IP {
    				t.Fatalf("Expected PodIP %q to equal PodIPs[0].IP %q", status.PodIP, status.PodIPs[0].IP)
    			}
    		})
    	}
    }
    
    func TestSortPodIPs(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  5. cni/pkg/util/podutil.go

    func GetPodIPsIfPresent(pod *corev1.Pod) []netip.Addr {
    	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
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. pkg/apis/core/v1/conversion.go

    		return err
    	}
    
    	// If both fields (v1.PodIPs and v1.PodIP) are provided and differ, then PodIP is authoritative for compatibility with older kubelets
    	if (len(in.PodIP) > 0 && len(in.PodIPs) > 0) && (in.PodIP != in.PodIPs[0].IP) {
    		out.PodIPs = []core.PodIP{
    			{
    				IP: in.PodIP,
    			},
    		}
    	}
    	// at the this point, autoConvert copied v1.PodIPs -> core.PodIPs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:30:55 UTC 2024
    - 19K bytes
    - Viewed (0)
  7. pkg/kubelet/config/common_test.go

    			}},
    			SecurityContext:    &v1.PodSecurityContext{},
    			SchedulerName:      v1.DefaultSchedulerName,
    			EnableServiceLinks: &enableServiceLinks,
    		},
    		Status: v1.PodStatus{
    			PodIP: "1.2.3.4",
    			PodIPs: []v1.PodIP{
    				{
    					IP: "1.2.3.4",
    				},
    			},
    		},
    	}
    	json, err := runtime.Encode(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), pod)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 18:40:48 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  8. pilot/pkg/controllers/untaint/nodeuntainter_test.go

    		pod.Status = corev1.PodStatus{}
    		newPod := s.pc.Create(pod)
    		if markReady {
    			setPodReady(newPod)
    		}
    		newPod.Status.PodIP = ip
    		newPod.Status.Phase = corev1.PodRunning
    		newPod.Status.PodIPs = []corev1.PodIP{
    			{
    				IP: ip,
    			},
    		}
    		s.pc.UpdateStatus(newPod)
    	} else {
    		s.pc.Update(pod)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/kuberuntime_sandbox.go

    			return nil
    		}
    		podIPs = append(podIPs, podSandbox.Network.Ip)
    	}
    
    	// pick additional ips, if cri reported them
    	for _, podIP := range podSandbox.Network.AdditionalIps {
    		if nil == netutils.ParseIPSloppy(podIP.Ip) {
    			klog.InfoS("Pod Sandbox reported an unparseable additional IP", "pod", klog.KRef(podNamespace, podName), "IP", podIP.Ip)
    			return nil
    		}
    		podIPs = append(podIPs, podIP.Ip)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_pods.go

    	podIPs := make([]string, len(podStatus.IPs))
    	copy(podIPs, podStatus.IPs)
    
    	// make podIPs order match node IP family preference #97979
    	podIPs = kl.sortPodIPs(podIPs)
    	for _, ip := range podIPs {
    		apiPodStatus.PodIPs = append(apiPodStatus.PodIPs, v1.PodIP{IP: ip})
    	}
    	if len(apiPodStatus.PodIPs) > 0 {
    		apiPodStatus.PodIP = apiPodStatus.PodIPs[0].IP
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top