- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for DeletePod (0.12 sec)
-
pkg/controller/statefulset/stateful_set_test.go
om.setsIndexer.Add(set1) om.setsIndexer.Add(set2) ssc.deletePod(logger, pod1) key, done := ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } ssc.deletePod(logger, pod2) key, done = ssc.queue.Get() if key == "" || done {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
deletePod(s, "pod") expectRemoved(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // Create pod we are not subscribed to; due to same-node optimization this will push createPod(s, "pod-same-node", "sa", "127.0.0.3", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod-same-node") deletePod(s, "pod-same-node")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
for _, set := range sets { ssc.enqueueStatefulSet(set) } } } // deletePod enqueues the statefulset for the pod accounting for deletion tombstones. func (ssc *StatefulSetController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
// attach/detach controller. // If the node does not exist this is a no-op. // If the node exists but has 1 or more child volumes, an error is returned. DeleteNode(nodeName k8stypes.NodeName) error // DeletePod removes the given pod from the list of pods that reference the // specified volume and are scheduled to the specified node. // If no pod exists in the list of pods that reference the specified volume
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// an rs never initiates a phase change, and so is never asleep waiting for the same. rsc.deletePod(logger, curPod) if labelChanged { // we don't need to check the oldPod.DeletionTimestamp because DeletionTimestamp cannot be unset. rsc.deletePod(logger, oldPod) } return } curControllerRef := metav1.GetControllerOf(curPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
type StatefulPodControlObjectManager interface { CreatePod(ctx context.Context, pod *v1.Pod) error GetPod(namespace, podName string) (*v1.Pod, error) UpdatePod(pod *v1.Pod) error DeletePod(pod *v1.Pod) error CreateClaim(claim *v1.PersistentVolumeClaim) error GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error) UpdateClaim(claim *v1.PersistentVolumeClaim) error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_test.go
"configmap:ns/cm3": {"node:node1=1", "node:node2=1", "node:node3=1"}, "serviceAccount:ns/sa1": {"node:node1=1", "node:node2=1", "node:node3=1"}, }) // delete one to drop below the threshold g.DeletePod("pod1", "ns") expectGraph(map[string][]string{ "node:node2": {}, "node:node3": {}, "pod:ns/pod2": {"node:node2"}, "pod:ns/pod3": {"node:node3"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:14:19 UTC 2022 - 12.3K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
if d == nil { return } logger.V(4).Info("ReplicaSet deleted", "replicaSet", klog.KObj(rs)) dc.enqueueDeployment(d) } // deletePod will enqueue a Recreate Deployment once all of its pods have stopped running. func (dc *DeploymentController) deletePod(logger klog.Logger, obj interface{}) { pod, ok := obj.(*v1.Pod) // When a delete is dropped, the relist will notice a pod in the store not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
if !volumeExists { t.Fatalf( "Added pod %q to volume %q/node %q. Volume does not exist, it should.", podName, generatedVolumeName, nodeName) } // Act dsw.DeletePod(types.UniquePodName(podName), generatedVolumeName, nodeName) // Assert volumeExists = dsw.VolumeExists(generatedVolumeName, nodeName) if volumeExists { t.Fatalf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/controller/replication/conversion.go
} func (pc podControlAdapter) DeletePod(ctx context.Context, namespace string, podID string, object runtime.Object) error { rc, err := convertRStoRC(object.(*apps.ReplicaSet)) if err != nil { return err } return pc.PodControlInterface.DeletePod(ctx, namespace, podID, rc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0)