- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,127 for removePod (0.15 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/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) -
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) -
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) -
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) -
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/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) -
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) -
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)