- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for deletedPods (0.18 sec)
-
cni/pkg/nodeagent/fakes_test.go
) //go:embed testdata/cgroupns var fakeProc embed.FS type fakeZtunnel struct { deletedPods atomic.Int32 addedPods atomic.Int32 addError error } func (f *fakeZtunnel) Run(ctx context.Context) { } func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error { f.deletedPods.Add(1) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 3.9K bytes - Viewed (0) -
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) -
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) -
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/scheduler/framework/plugins/nodeports/node_ports.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K 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) -
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)