Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for startedStaticPodsByFullname (0.44 sec)

  1. pkg/kubelet/pod_workers_test.go

    			}
    
    			// if maps are neither nil nor empty
    			if len(podWorkers.startedStaticPodsByFullname) != 0 ||
    				len(podWorkers.startedStaticPodsByFullname) != len(tc.expectedStartedStaticPodsByFullname) {
    				if !reflect.DeepEqual(
    					podWorkers.startedStaticPodsByFullname,
    					tc.expectedStartedStaticPodsByFullname) {
    					t.Errorf("startedStaticPodsByFullname: expected %v, got %v",
    						tc.expectedStartedStaticPodsByFullname,
    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

    	}
    	status.finished = true
    	status.working = false
    	status.terminatedAt = p.clock.Now()
    
    	if p.startedStaticPodsByFullname[status.fullname] == pod.UID {
    		delete(p.startedStaticPodsByFullname, status.fullname)
    	}
    }
    
    // startPodSync is invoked by each pod worker goroutine when a message arrives on the pod update channel.
    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/kubelet_pods_test.go

    				// send a create of a static pod
    				pod := staticPod()
    				// block startup of the static pod due to full name collision
    				w.startedStaticPodsByFullname[kubecontainer.GetPodFullName(pod)] = types.UID("2")
    
    				w.UpdatePod(UpdatePodOptions{
    					UpdateType: kubetypes.SyncPodCreate,
    					StartTime:  time.Unix(1, 0).UTC(),
    					Pod:        pod,
    				})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top