Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for deletedPods (0.21 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. 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)
  4. pkg/controller/volume/pvcprotection/pvc_protection_controller_test.go

    		}
    		switch {
    		case test.deletedPod != nil && test.updatedPod != nil && test.deletedPod.Namespace == test.updatedPod.Namespace && test.deletedPod.Name == test.updatedPod.Name:
    			ctrl.podAddedDeletedUpdated(logger, test.deletedPod, test.updatedPod, false)
    		case test.updatedPod != nil:
    			ctrl.podAddedDeletedUpdated(logger, nil, test.updatedPod, false)
    		case test.deletedPod != nil:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 15.5K 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. 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)
  8. pkg/kubelet/config/config.go

    				if needUpdate {
    					updatePods = append(updatePods, existing)
    				} else if needReconcile {
    					reconcilePods = append(reconcilePods, existing)
    				} else if needGracefulDelete {
    					deletePods = append(deletePods, existing)
    				}
    				continue
    			}
    			recordFirstSeenTime(ref)
    			pods[ref.UID] = ref
    			addPods = append(addPods, ref)
    		}
    	}
    
    	update := change.(kubetypes.PodUpdate)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. pkg/registry/core/pod/storage/eviction.go

    		if err != nil {
    			return err
    		}
    		deletedPod = true
    		return nil
    	})
    	switch {
    	case err != nil:
    		// this can happen in cases where the PDB can be ignored, but there was a problem issuing the pod delete:
    		// maybe we conflicted too many times or we didn't have permission or something else weird.
    		return nil, err
    
    	case deletedPod:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 11:58:48 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  10. pkg/kubelet/config/config_test.go

    	// mark this pod as deleted
    	timestamp := metav1.NewTime(time.Now())
    	deletedPod := CreateValidPod("foo", "new")
    	deletedPod.ObjectMeta.DeletionTimestamp = &timestamp
    	podUpdate = CreatePodUpdate(kubetypes.DELETE, TestSource, deletedPod)
    	channel <- podUpdate
    	// the existing pod should be gracefully deleted
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
Back to top