Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,127 for removePod (0.15 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/testing/fake_manager.go

    // FakeManager simulates a prober.Manager for testing.
    type FakeManager struct{}
    
    // Unused methods below.
    
    // AddPod simulates adding a Pod.
    func (FakeManager) AddPod(_ *v1.Pod) {}
    
    // RemovePod simulates removing a Pod.
    func (FakeManager) RemovePod(_ *v1.Pod) {}
    
    // Simulated stopping liveness and startup probes.
    func (FakeManager) StopLivenessAndStartup(_ *v1.Pod) {}
    
    // CleanupPods simulates cleaning up Pods.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/cache/fake/fake_cache.go

    // UpdatePod is a fake method for testing.
    func (c *Cache) UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error { return nil }
    
    // RemovePod is a fake method for testing.
    func (c *Cache) RemovePod(logger klog.Logger, pod *v1.Pod) error { return nil }
    
    // IsAssumedPod is a fake method for testing.
    func (c *Cache) IsAssumedPod(pod *v1.Pod) (bool, error) {
    	return c.IsAssumedPodFunc(pod), nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  4. pkg/kubelet/pod/pod_manager_test.go

    		},
    		staticPod,
    	}
    	updates := append(expectedPods, mirrorPod)
    	podManager, _ := newTestManager()
    	podManager.SetPods(updates)
    
    	podManager.RemovePod(staticPod)
    
    	actualPods := podManager.GetPods()
    	if len(actualPods) == len(expectedPods) {
    		t.Fatalf("Run RemovePod() error, expected %d pods, got %d pods; ", len(expectedPods)-1, len(actualPods))
    	}
    
    	_, _, orphanedMirrorPodNames := podManager.GetPodsAndMirrorPods()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/cache/interface.go

    	// UpdatePod removes oldPod's information and adds newPod's information.
    	UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error
    
    	// RemovePod removes a pod. The pod's information would be subtracted from assigned node.
    	RemovePod(logger klog.Logger, pod *v1.Pod) error
    
    	// GetPod returns the pod from the cache with the same namespace and the
    	// same name of the specified pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  6. 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)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    	nodeInfo *framework.NodeInfo,
    	pdbs []*policy.PodDisruptionBudget) ([]*v1.Pod, int, *framework.Status) {
    	logger := klog.FromContext(ctx)
    	var potentialVictims []*framework.PodInfo
    	removePod := func(rpi *framework.PodInfo) error {
    		if err := nodeInfo.RemovePod(logger, rpi.Pod); err != nil {
    			return err
    		}
    		status := pl.fh.RunPreFilterExtensionRemovePod(ctx, state, pod, rpi, nodeInfo)
    		if !status.IsSuccess() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/cache/cache.go

    	key, err := framework.GetPodKey(pod)
    	if err != nil {
    		return err
    	}
    
    	n, ok := cache.nodes[pod.Spec.NodeName]
    	if !ok {
    		logger.Error(nil, "Node not found when trying to remove pod", "node", klog.KRef("", pod.Spec.NodeName), "podKey", key, "pod", klog.KObj(pod))
    	} else {
    		if err := n.info.RemovePod(logger, pod); err != nil {
    			return err
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top