- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for DeletePod (0.13 sec)
-
plugin/pkg/auth/authorizer/node/graph_populator.go
startTime := time.Now() g.graph.DeletePod(pod.Name, pod.Namespace) klog.V(5).Infof("deletePod %s/%s for node %s completed in %v", pod.Namespace, pod.Name, pod.Spec.NodeName, time.Since(startTime)) } func (g *graphPopulator) addPV(obj interface{}) { g.updatePV(nil, obj) } func (g *graphPopulator) updatePV(oldObj, obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
return err } // Start the pod _, err = recyclerClient.CreatePod(pod) if err != nil { if errors.IsAlreadyExists(err) { deleteErr := recyclerClient.DeletePod(pod.Name, pod.Namespace) if deleteErr != nil { return fmt.Errorf("failed to delete old recycler pod %s/%s: %s", pod.Namespace, pod.Name, deleteErr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go
// from the informer, delete it from dsw logger.V(1).Info("Removing pod from dsw because it does not exist in pod informer", "podName", dswPodKey, "podUID", dswPodUID) dswp.desiredStateOfWorld.DeletePod(dswPodUID, dswPodToAdd.VolumeName, dswPodToAdd.NodeName) } // check if the existing volumes changes its attachability for _, volumeToAttach := range dswp.desiredStateOfWorld.GetVolumesToAttach() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
if !volumeExists { t.Fatalf( "VolumeExists(%q) failed. Expected: <true> Actual: <%v>", expectedVolumeName, volumeExists) } //delete the pod and volume manually dswp.desiredStateOfWorld.DeletePod(podName, expectedVolumeName, k8stypes.NodeName(pod.Spec.NodeName)) //check if the given volume referenced by the pod still exists in dsw
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client_test.go
func (c *mockRecyclerClient) GetPod(name, namespace string) (*v1.Pod, error) { if c.pod != nil { return c.pod, nil } return nil, fmt.Errorf("pod does not exist") } func (c *mockRecyclerClient) DeletePod(name, namespace string) error { c.deletedCalled = true return nil } func (c *mockRecyclerClient) WatchPod(name, namespace string, stopChannel chan struct{}) (<-chan watch.Event, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 8.5K bytes - Viewed (0)