Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for deletedPods (0.15 sec)

  1. cni/pkg/nodeagent/net_test.go

    		Netns:    fakens,
    	}
    	fixture.podNsMap.UpsertPodCacheWithNetns(string(pod.UID), workload)
    	err := netServer.RemovePodFromMesh(ctx, pod)
    	assert.NoError(t, err)
    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1)
    	assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1)
    	// make sure the uid was taken from cache and netns closed
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_control.go

    	// Now we need to delete MaxUnavailable- unavailablePods
    	// start deleting one by one starting from the highest ordinal first
    	podsToDelete := maxUnavailable - unavailablePods
    
    	deletedPods := 0
    	for target := len(replicas) - 1; target >= updateMin && deletedPods < podsToDelete; target-- {
    
    		// delete the Pod if it is healthy and the revision doesnt match the target
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	if err != nil {
    		t.Fatalf("Unexpected error: %v", err)
    	}
    	deletedPods := deleted.(*example.PodList)
    	if len(deletedPods.Items) != numPods {
    		t.Errorf("Unexpected number of pods deleted: %d, expected: %d", len(deletedPods.Items), numPods)
    	}
    	expectedCalls := (int64(numPods) + deleteCollectionPageSize - 1) / deleteCollectionPageSize
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  4. pkg/serviceaccount/claims_test.go

    			deletedServiceAccount = serviceAccount.DeepCopy()
    			deletedPod            = pod.DeepCopy()
    			deletedSecret         = secret.DeepCopy()
    			deletedNode           = node.DeepCopy()
    		)
    		deletedServiceAccount.DeletionTimestamp = deletionTestCase.time
    		deletedPod.DeletionTimestamp = deletionTestCase.time
    		deletedSecret.DeletionTimestamp = deletionTestCase.time
    		deletedNode.DeletionTimestamp = deletionTestCase.time
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    			if !test.deletedPodNotScheduled {
    				test.deletedPod.Spec.NodeName = node.Node().Name
    			} else {
    				test.deletedPod.Spec.NodeName = ""
    			}
    
    			p := &CSILimits{
    				randomVolumeIDPrefix: rand.String(32),
    				translator:           csitrans.New(),
    			}
    			logger, _ := ktesting.NewTestContext(t)
    			qhint, err := p.isSchedulableAfterPodDeleted(logger, test.newPod, test.deletedPod, nil)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  6. pkg/controller/testutil/test_utils.go

    		if !contains(m.UpdatedNodes[i], m.DeletedNodes) {
    			nodes = append(nodes, m.UpdatedNodes[i])
    		}
    	}
    	for i := 0; i < len(m.Existing); i++ {
    		if !contains(m.Existing[i], m.DeletedNodes) && !contains(m.Existing[i], nodes) {
    			nodes = append(nodes, m.Existing[i])
    		}
    	}
    	for i := 0; i < len(m.CreatedNodes); i++ {
    		if !contains(m.CreatedNodes[i], m.DeletedNodes) && !contains(m.CreatedNodes[i], nodes) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. cni/pkg/config/config.go

    	b.WriteString("NodeName: " + c.NodeName + "\n")
    	b.WriteString("LabelKey: " + c.LabelKey + "\n")
    	b.WriteString("LabelValue: " + c.LabelValue + "\n")
    	b.WriteString("DeletePods: " + fmt.Sprint(c.DeletePods) + "\n")
    	b.WriteString("LabelPods: " + fmt.Sprint(c.LabelPods) + "\n")
    	b.WriteString("SidecarAnnotation: " + c.SidecarAnnotation + "\n")
    	b.WriteString("InitContainerName: " + c.InitContainerName + "\n")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	deletedPod, _, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, fmt.Errorf("unexpected objects in isSchedulableAfterPodDeleted: %w", err)
    	}
    
    	if len(deletedPod.Spec.Volumes) == 0 {
    		return framework.QueueSkip, nil
    	}
    
    	if deletedPod.Spec.NodeName == "" {
    		return framework.QueueSkip, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  9. manifests/charts/istio-cni/templates/configmap-cni.yaml

      REPAIR_ENABLED: {{ .Values.cni.chained | quote }}
      REPAIR_LABEL_PODS: {{ .Values.cni.repair.labelPods | quote }}
      REPAIR_DELETE_PODS: {{ .Values.cni.repair.deletePods | quote }}
      REPAIR_REPAIR_PODS: {{ .Values.cni.repair.repairPods | quote }}
      REPAIR_INIT_CONTAINER_NAME: {{ .Values.cni.repair.initContainerName | quote }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 16:52:25 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. manifests/charts/istio-cni/values.yaml

          labelPods: false
          # deletePods will delete any broken pod. These will then be rescheduled, hopefully onto a node that is fully ready.
          # Note this gives the DaemonSet a relatively high privilege, as it can delete any Pod.
          deletePods: false
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top