- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for deletedPods (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/config/config_test.go
// mark this pod as deleted timestamp := metav1.NewTime(time.Now()) deletedPod := CreateValidPod("foo", "new") deletedPod.ObjectMeta.DeletionTimestamp = ×tamp 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)