- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,138 for removePod (0.21 sec)
-
pkg/kubelet/pod/testing/mock_manager.go
} // RemovePod mocks base method. func (m *MockManager) RemovePod(pod *v1.Pod) { m.ctrl.T.Helper() m.ctrl.Call(m, "RemovePod", pod) } // RemovePod indicates an expected call of RemovePod. func (mr *MockManagerMockRecorder) RemovePod(pod any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemovePod", reflect.TypeOf((*MockManager)(nil).RemovePod), pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager_test.go
} // Removing un-probed pod. m.RemovePod(&noProbePod) if err := expectProbes(m, probePaths); err != nil { t.Error(err) } // Removing probed pod. m.RemovePod(&probePod) if err := waitForWorkerExit(t, m, probePaths); err != nil { t.Fatal(err) } if err := expectProbes(m, nil); err != nil { t.Error(err) } // Removing already removed pods should be a no-op. m.RemovePod(&probePod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
AddPod(pod *v1.Pod) // UpdatePod updates the given pod in the manager. UpdatePod(pod *v1.Pod) // RemovePod deletes the given pod from the manager. For mirror pods, // this means deleting the mappings related to mirror pods. For non- // mirror pods, this means deleting from indexes for all non-mirror pods. RemovePod(pod *v1.Pod) // TranslatePodUID returns the actual UID of a pod. If the UID belongs to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
// and get cached node info by given node name. nodeInfoCopy := f.CachedNodeNameToInfo[node.Node().Name].Snapshot() var potentialVictims []*v1.Pod removePod := func(rp *v1.Pod) error { return nodeInfoCopy.RemovePod(logger, rp) } addPod := func(ap *v1.Pod) { nodeInfoCopy.AddPod(ap) } // As the first step, remove all the lower priority pods from the node and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
if err != nil { return framework.AsStatus(err) } pl.updateWithPod(s, podInfoToAdd.Pod, podToSchedule, nodeInfo.Node(), 1) return nil } // RemovePod from pre-computed data in cycleState. func (pl *PodTopologySpread) RemovePod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
dswp.podManager.(mutablePodManager).RemovePod(pod) dswp.findAndRemoveDeletedPods() if !dswp.pods.processedPods[podName] { t.Fatalf("Pod should not been removed from desired state of world since pod state still thinks it exists") } fakePodState.removed = map[kubetypes.UID]struct{}{pod.UID: {}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
AddPod(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, podInfoToAdd *PodInfo, nodeInfo *NodeInfo) *Status // RemovePod is called by the framework while trying to evaluate the impact // of removing podToRemove from the node while scheduling podToSchedule. RemovePod(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, podInfoToRemove *PodInfo, nodeInfo *NodeInfo) *Status }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
if len(s) == 0 { return nil, removed } return s, removed } // RemovePod subtracts pod information from this NodeInfo. func (n *NodeInfo) RemovePod(logger klog.Logger, pod *v1.Pod) error { k, err := GetPodKey(pod) if err != nil { return err } if podWithAffinity(pod) { n.PodsWithAffinity, _ = removeFromSlice(logger, n.PodsWithAffinity, k) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
if !status.IsSuccess() { err := status.AsError() logger.Error(err, "Plugin failed", "node", klog.KObj(nodeInfo.Node()), "operation", "removePod", "plugin", pl.Name(), "pod", klog.KObj(podToSchedule)) return framework.AsStatus(fmt.Errorf("running RemovePod on PreFilter plugin %q: %w", pl.Name(), err)) } } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
logger.Error(nil, "Cannot convert to *v1.Pod", "obj", t) return } logger.V(3).Info("Delete event for scheduled pod", "pod", klog.KObj(pod)) if err := sched.Cache.RemovePod(logger, pod); err != nil { logger.Error(err, "Scheduler cache RemovePod failed", "pod", klog.KObj(pod)) } sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, queue.AssignedPodDelete, pod, nil, nil) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0)