Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PodID (0.63 sec)

  1. pkg/kubelet/server/server.go

    		Path("/attach")
    	ws.Route(ws.GET("/{podNamespace}/{podID}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.GET("/{podNamespace}/{podID}/{uid}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}/{containerName}").
    		To(s.getAttach).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  2. pkg/kubelet/pleg/generic.go

    	return true, nil
    }
    
    func generateEvents(podID types.UID, cid string, oldState, newState plegContainerState) []*PodLifecycleEvent {
    	if newState == oldState {
    		return nil
    	}
    
    	klog.V(4).InfoS("GenericPLEG", "podUID", podID, "containerID", cid, "oldState", oldState, "newState", newState)
    	switch newState {
    	case plegContainerRunning:
    		return []*PodLifecycleEvent{{ID: podID, Type: ContainerStarted, Data: cid}}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    func (u *UnschedulablePods) addOrUpdate(pInfo *framework.QueuedPodInfo) {
    	podID := u.keyFunc(pInfo.Pod)
    	if _, exists := u.podInfoMap[podID]; !exists {
    		if pInfo.Gated && u.gatedRecorder != nil {
    			u.gatedRecorder.Inc()
    		} else if !pInfo.Gated && u.unschedulableRecorder != nil {
    			u.unschedulableRecorder.Inc()
    		}
    	}
    	u.podInfoMap[podID] = pInfo
    }
    
    // delete deletes a pod from the unschedulable podInfoMap.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			if _, ok, _ := q.podBackoffQ.Get(podInfo); !ok {
    				t.Errorf("pod %v is not in the backoff queue", podID)
    			}
    			// Moved out of the backoff queue after timeout.
    			cl.Step(backoff)
    			q.flushBackoffQCompleted(logger)
    			if _, ok, _ := q.podBackoffQ.Get(podInfo); ok {
    				t.Errorf("pod %v is still in the backoff queue", podID)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    func (kl *Kubelet) cleanUpContainersInPod(podID types.UID, exitedContainerID string) {
    	if podStatus, err := kl.podCache.Get(podID); err == nil {
    		// When an evicted or deleted pod has already synced, all containers can be removed.
    		removeAll := kl.podWorkers.ShouldPodContentBeRemoved(podID)
    		kl.containerDeletor.deleteContainersInPod(exitedContainerID, podStatus, removeAll)
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top