Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 236 for podutil (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/controller/daemon/daemon_controller.go

    		if ds == nil {
    			return
    		}
    		logger.V(4).Info("Pod updated", "pod", klog.KObj(curPod))
    		dsc.enqueueDaemonSet(ds)
    		changedToReady := !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod)
    		// See https://github.com/kubernetes/kubernetes/pull/38076 for more details
    		if changedToReady && ds.Spec.MinReadySeconds > 0 {
    			// Add a second to avoid milliseconds skew in AddAfter.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  5. 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)
  6. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    			pod:       pod,
    			container: c,
    			createdAt: fakeCreatedAt,
    			state:     runtimeapi.ContainerState_CONTAINER_RUNNING,
    		}
    	}
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool {
    		containers = append(containers, makeFakeContainer(t, m, newTemplate(c)))
    		return true
    	})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  7. 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)
  8. pkg/controller/statefulset/stateful_set.go

    		// the Pod status which in turn will trigger a requeue of the owning replica set thus
    		// having its status updated with the newly available replica.
    		if !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) && set.Spec.MinReadySeconds > 0 {
    			logger.V(2).Info("StatefulSet will be enqueued after minReadySeconds for availability check", "statefulSet", klog.KObj(set), "minReadySeconds", set.Spec.MinReadySeconds)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  9. pkg/controller/replicaset/replica_set.go

    		// a Pod transitioned to Ready.
    		// Note that this still suffers from #29229, we are just moving the problem one level
    		// "closer" to kubelet (from the deployment to the replica set controller).
    		if !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) && rs.Spec.MinReadySeconds > 0 {
    			logger.V(2).Info("pod will be enqueued after a while for availability check", "duration", rs.Spec.MinReadySeconds, "kind", rsc.Kind, "pod", klog.KObj(oldPod))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/types.go

    		ContainerFn: func(requests v1.ResourceList, containerType podutil.ContainerType) {
    			non0CPUReq, non0MemReq := schedutil.GetNonzeroRequests(&requests)
    			switch containerType {
    			case podutil.Containers:
    				non0CPU += non0CPUReq
    				non0Mem += non0MemReq
    			case podutil.InitContainers:
    				non0InitCPU = max(non0InitCPU, non0CPUReq)
    				non0InitMem = max(non0InitMem, non0MemReq)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
Back to top