Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,389 for podIps (0.27 sec)

  1. pkg/quota/v1/evaluator/core/pods.go

    	// where "pods" tracks all pods that have not reached a terminal state,
    	// count/pods tracks all pods independent of state.
    	result := corev1.ResourceList{
    		podObjectCountName: *(resource.NewQuantity(1, resource.DecimalSI)),
    	}
    
    	// by convention, we do not quota compute resources that have reached end-of life
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 17.4K bytes
    - Viewed (0)
  2. pkg/apis/core/v1/zz_generated.conversion.go

    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*v1.PodIP)(nil), (*core.PodIP)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_PodIP_To_core_PodIP(a.(*v1.PodIP), b.(*core.PodIP), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*core.PodIP)(nil), (*v1.PodIP)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 472.1K bytes
    - Viewed (0)
  3. pkg/printers/internalversion/printers_test.go

    							Status: api.ConditionFalse,
    						},
    						{
    							Type:   api.PodConditionType(condition2),
    							Status: api.ConditionTrue,
    						},
    					},
    					Phase:  "podPhase",
    					PodIPs: []api.PodIP{{IP: "1.1.1.1"}},
    					ContainerStatuses: []api.ContainerStatus{
    						{Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}},
    						{RestartCount: 3},
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  4. pkg/registry/core/service/storage/storage_test.go

    		},
    		Status: api.PodStatus{
    			PodIPs: []api.PodIP{},
    		},
    	}
    
    	for _, ip := range ips {
    		p.Status.PodIPs = append(p.Status.PodIPs, api.PodIP{IP: ip})
    	}
    
    	return p
    }
    
    func TestServiceRegistryResourceLocation(t *testing.T) {
    	pods := []api.Pod{
    		makePod("unnamed", "1.2.3.4", "1.2.3.5"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.22.md

    consequence of this change the Kubelet now correctly takes into account the resources of running and terminating pods when deciding to accept new pods, since terminating pods are still holding on to those resources. This stricter handling may surface to end users as pod rejections when creating pods that are scheduled to mostly full nodes that have other terminating pods holding the resources the new pods need. The most likely error would be a pod set to `Failed` phase with reason set to `OutOfCpu` or `OutOfMemory`,...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 13 12:43:45 UTC 2022
    - 454.1K bytes
    - Viewed (0)
  6. src/internal/coverage/pods/pods.go

    			pod.Origins = append(pod.Origins, e.origin)
    			pod.ProcessIDs = append(pod.ProcessIDs, e.pid)
    		}
    		pods = append(pods, pod)
    	}
    	slices.SortFunc(pods, func(a, b Pod) int {
    		return strings.Compare(a.MetaFile, b.MetaFile)
    	})
    	return pods
    }
    
    func warning(s string, a ...interface{}) {
    	fmt.Fprintf(os.Stderr, "warning: ")
    	fmt.Fprintf(os.Stderr, s, a...)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. cmd/kubeadm/test/resources/pods.go

    }
    
    // CreateWithPodSuffix creates a fake static pod using the provided
    // client and suffix
    func (p *FakeStaticPod) CreateWithPodSuffix(client clientset.Interface, suffix string) error {
    	_, err := client.CoreV1().Pods(metav1.NamespaceSystem).Create(context.TODO(), p.Pod(suffix), metav1.CreateOptions{})
    	return err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 17 14:40:46 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/core/v1/generated.pb.go

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			m.PodIPs = append(m.PodIPs, PodIP{})
    			if err := m.PodIPs[len(m.PodIPs)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 13:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 1.8M bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    		}
    		logger.V(5).Info("a scheduled pod was updated but it doesn't match the target pod's affinity or does match the target pod's anti-affinity",
    			"pod", klog.KObj(pod), "modifiedPod", klog.KObj(modifiedPod))
    		return framework.QueueSkip, nil
    	}
    
    	// Pod is added. Return Queue when the added pod matching the target pod's affinity.
    	if modifiedPod != nil {
    		if podMatchesAllAffinityTerms(terms, modifiedPod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. pkg/kube/krt/collection_test.go

    	Named
    	Labeled
    	IP string
    }
    
    func SimplePodCollection(pods krt.Collection[*corev1.Pod]) krt.Collection[SimplePod] {
    	return krt.NewCollection(pods, func(ctx krt.HandlerContext, i *corev1.Pod) *SimplePod {
    		if i.Status.PodIP == "" {
    			return nil
    		}
    		return &SimplePod{
    			Named:   NewNamed(i),
    			Labeled: NewLabeled(i.Labels),
    			IP:      i.Status.PodIP,
    		}
    	})
    }
    
    type SizedPod struct {
    	Named
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
Back to top