Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 136 for podutil (0.2 sec)

  1. pkg/registry/core/pod/strategy.go

    		// as a signal to the caller that the request is being considered.
    		podutil.MarkPodProposedForResize(oldPod, newPod)
    	}
    
    	podutil.DropDisabledPodFields(newPod, oldPod)
    }
    
    // Validate validates a new pod.
    func (podStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList {
    	pod := obj.(*api.Pod)
    	opts := podutil.GetValidationOptionsFromPodSpecAndMeta(&pod.Spec, nil, &pod.ObjectMeta, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  2. pkg/kubelet/container/helpers.go

    // GetContainerSpec gets the container spec by containerName.
    func GetContainerSpec(pod *v1.Pod, containerName string) *v1.Container {
    	var containerSpec *v1.Container
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool {
    		if containerName == c.Name {
    			containerSpec = c
    			return false
    		}
    		return true
    	})
    	return containerSpec
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. pkg/controller/controller_utils.go

    	}
    	// 3. ready < not ready
    	if podutil.IsPodReady(s[i]) != podutil.IsPodReady(s[j]) {
    		return podutil.IsPodReady(s[i])
    	}
    	// TODO: take availability into account when we push minReadySeconds information from deployment into pods,
    	//       see https://github.com/kubernetes/kubernetes/issues/22065
    	// 4. Been ready for more time < less time < empty time
    	if podutil.IsPodReady(s[i]) && podutil.IsPodReady(s[j]) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  4. pkg/kubelet/status/status_manager.go

    	// See https://issues.k8s.io/108594 for more details.
    	if podutil.IsPodPhaseTerminal(newPodStatus.Phase) {
    		if podutil.IsPodReadyConditionTrue(newPodStatus) || podutil.IsContainersReadyConditionTrue(newPodStatus) {
    			containersReadyCondition := generateContainersReadyConditionForTerminalPhase(newPodStatus.Phase)
    			podutil.UpdatePodCondition(&newPodStatus, &containersReadyCondition)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  5. pkg/volume/util/util.go

    	mounts = sets.New[string]()
    	devices = sets.New[string]()
    	seLinuxContainerContexts = make(map[string][]*v1.SELinuxOptions)
    
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(container *v1.Container, containerType podutil.ContainerType) bool {
    		var seLinuxOptions *v1.SELinuxOptions
    		if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  6. pkg/controller/daemon/update.go

    			case newPod != nil:
    				// this pod is up to date, check its availability
    				if !podutil.IsPodAvailable(newPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}) {
    					// an unavailable new pod is counted against maxUnavailable
    					numUnavailable++
    				}
    			default:
    				// this pod is old, it is an update candidate
    				switch {
    				case !podutil.IsPodAvailable(oldPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}):
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  7. pkg/controller/daemon/update_test.go

    		if pod.DeletionTimestamp != nil {
    			continue
    		}
    		if podutil.IsPodReady(pod) == ready {
    			continue
    		}
    		if !fn(pod) {
    			continue
    		}
    		condition := v1.PodCondition{Type: v1.PodReady}
    		if ready {
    			condition.Status = v1.ConditionTrue
    		} else {
    			condition.Status = v1.ConditionFalse
    		}
    		if !podutil.UpdatePodCondition(&pod.Status, &condition) {
    			t.Fatal("failed to update pod")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 10 21:10:35 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  8. plugin/pkg/admission/noderestriction/admission.go

    	}
    	hasSecrets := false
    	podutil.VisitPodSecretNames(pod, func(name string) (shouldContinue bool) { hasSecrets = true; return false }, podutil.AllContainers)
    	if hasSecrets {
    		return admission.NewForbidden(a, fmt.Errorf("node %q can not create pods that reference secrets", nodeName))
    	}
    	hasConfigMaps := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  9. plugin/pkg/auth/authorizer/node/graph.go

    		g.addEdgeToDestinationIndex_locked(e)
    	}
    
    	podutil.VisitPodSecretNames(pod, func(secret string) bool {
    		secretVertex := g.getOrCreateVertex_locked(secretVertexType, pod.Namespace, secret)
    		e := newDestinationEdge(secretVertex, podVertex, nodeVertex)
    		g.graph.SetEdge(e)
    		g.addEdgeToDestinationIndex_locked(e)
    		return true
    	})
    
    	podutil.VisitPodConfigmapNames(pod, func(configmap string) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  10. plugin/pkg/admission/serviceaccount/admission.go

    			return admission.NewForbidden(a, fmt.Errorf("a mirror pod may not reference service accounts"))
    		}
    		hasSecrets := false
    		podutil.VisitPodSecretNames(pod, func(name string) bool {
    			hasSecrets = true
    			return false
    		}, podutil.AllContainers)
    		if hasSecrets {
    			return admission.NewForbidden(a, fmt.Errorf("a mirror pod may not reference secrets"))
    		}
    		for _, v := range pod.Spec.Volumes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
Back to top