Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for runningPod (0.22 sec)

  1. pkg/kubelet/pod_workers_test.go

    				return nil
    			},
    			syncTerminatingRuntimePod: func(ctx context.Context, runningPod *kubecontainer.Pod) error {
    				func() {
    					lock.Lock()
    					defer lock.Unlock()
    					processed[runningPod.ID] = append(processed[runningPod.ID], syncPodRecord{
    						name:       runningPod.Name,
    						updateType: kubetypes.SyncPodKill,
    						runningPod: runningPod,
    					})
    				}()
    				return nil
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  2. pkg/kubelet/pod_workers.go

    	var uid types.UID
    	var name, ns string
    	if runningPod := options.RunningPod; runningPod != nil {
    		if options.Pod == nil {
    			// the sythetic pod created here is used only as a placeholder and not tracked
    			if options.UpdateType != kubetypes.SyncPodKill {
    				klog.InfoS("Pod update is ignored, runtime pods can only be killed", "pod", klog.KRef(runningPod.Namespace, runningPod.Name), "podUID", runningPod.ID, "updateType", options.UpdateType)
    				return
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_container.go

    				killContainerResult.Fail(kubecontainer.ErrKillContainer, err.Error())
    				// Use runningPod for logging as the pod passed in could be *nil*.
    				klog.ErrorS(err, "Kill container failed", "pod", klog.KRef(runningPod.Namespace, runningPod.Name), "podUID", runningPod.ID,
    					"containerName", container.Name, "containerID", container.ID)
    			}
    			containerResults <- killContainerResult
    		}(container)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    func (m *kubeGenericRuntimeManager) KillPod(ctx context.Context, pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error {
    	err := m.killPodWithSyncResult(ctx, pod, runningPod, gracePeriodOverride)
    	return err.Error()
    }
    
    // killPodWithSyncResult kills a runningPod and returns SyncResult.
    // Note: The pod passed in could be *nil* when kubelet restarted.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    			Image:    fakeContainer.Image,
    			ImageRef: fakeContainer.ImageRef,
    			Labels:   fakeContainer.Labels,
    		})
    		if err != nil {
    			t.Fatalf("unexpected error %v", err)
    		}
    		containers[i] = c
    	}
    	runningPod := kubecontainer.Pod{
    		ID:         pod.UID,
    		Name:       pod.Name,
    		Namespace:  pod.Namespace,
    		Containers: []*kubecontainer.Container{containers[0], containers[1], containers[2]},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  6. pkg/kubelet/server/server_test.go

    		"run with uid":                    {url: "/run/podNamespace/podID/uid/containerName", bucket: "run"},
    		"runningpods":                     {url: "/runningpods/", bucket: "runningpods"},
    		"stats":                           {url: "/stats/", bucket: "stats"},
    		"stats summary sub":               {url: "/stats/summary", bucket: "stats"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top