- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for newNode (0.34 sec)
-
pkg/controller/tainteviction/taint_eviction_test.go
newNode: addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}), expectPatch: true, expectDelete: true, }, { description: "new pod2 created on tainted Node", pods: []corev1.Pod{ *testutil.NewPod("pod1", "node1"), }, prevPod: nil, newPod: testutil.NewPod("pod2", "node1"), oldNode: testutil.NewNode("node1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
patchedPodNames sets.Set[string] enablePodDisruptionConditions bool }{ { name: "nodes present in lister", initialInformerNodes: []*v1.Node{ testutil.NewNode("existing1"), testutil.NewNode("existing2"), }, delay: 2 * quarantineTime, pods: []*v1.Pod{ makePod("a", "existing1", v1.PodRunning), makePod("b", "existing2", v1.PodFailed),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
func (tc *Controller) NodeUpdated(oldNode *v1.Node, newNode *v1.Node) { nodeName := "" oldTaints := []v1.Taint{} if oldNode != nil { nodeName = oldNode.Name oldTaints = getNoExecuteTaints(oldNode.Spec.Taints) } newTaints := []v1.Taint{} if newNode != nil { nodeName = newNode.Name newTaints = getNoExecuteTaints(newNode.Spec.Taints) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
newPod1 := controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{newPod1}, []*v1.Pod{}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{}, []*v1.Pod{newPod1}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
return &FakeRecorder{ source: v1.EventSource{Component: "nodeControllerTest"}, Events: []*v1.Event{}, clock: testingclock.NewFakeClock(time.Now()), } } // NewNode is a helper function for creating Nodes for testing. func NewNode(name string) *v1.Node { return &v1.Node{ ObjectMeta: metav1.ObjectMeta{Name: name}, Status: v1.NodeStatus{ Capacity: v1.ResourceList{
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/volume/csi/nodeinfomanager/nodeinfomanager.go
if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false for _, update := range updateFuncs { newNode, updated, err := update(node) if err != nil { return err } node = newNode needUpdate = needUpdate || updated } if needUpdate { // PatchNodeStatus can update both node's status and labels or annotations
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
newNode := &node{ identity: identityFromEvent(event, accessor), dependents: make(map[*node]struct{}), owners: accessor.GetOwnerReferences(), deletingDependents: beingDeleted(accessor) && hasDeleteDependentsFinalizer(accessor), beingDeleted: beingDeleted(accessor), } gb.insertNode(logger, newNode)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/AbstractSmokeTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 08:14:32 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
wantPreFilterStatus *framework.Status }{ { newPod: csiEBSOneVolPod, existingPods: []*v1.Pod{runningPod, csiEBSTwoVolPod}, filterName: "csi", maxVols: 4, driverNames: []string{ebsCSIDriverName}, test: "fits when node volume limit >= new pods CSI volume", limitSource: "node", }, { newPod: csiEBSOneVolPod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// For update, we just need to handle opt outs newPod := event.New.(*corev1.Pod) oldPod := event.Old.(*corev1.Pod) ns := s.namespaces.Get(newPod.Namespace, "") if ns == nil { return fmt.Errorf("failed to find namespace %v", ns) } wasAnnotated := oldPod.Annotations != nil && oldPod.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0)