Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,138 for removePod (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top