Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for IsStaticPod (0.28 sec)

  1. pkg/kubelet/pod_workers.go

    			if status.activeUpdate.Pod != nil {
    				sync.HasConfig = true
    				sync.Static = kubetypes.IsStaticPod(status.activeUpdate.Pod)
    			}
    		case status.pendingUpdate != nil:
    			if status.pendingUpdate.Pod != nil {
    				sync.HasConfig = true
    				sync.Static = kubetypes.IsStaticPod(status.pendingUpdate.Pod)
    			}
    		}
    		workers[uid] = sync
    	}
    	return workers
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  2. pkg/kubelet/status/status_manager_test.go

    	}
    	client := fake.NewSimpleClientset(mirrorPod)
    	m := newTestManager(client)
    
    	t.Logf("Create the static pod")
    	m.podManager.(mutablePodManager).AddPod(staticPod)
    	assert.True(t, kubetypes.IsStaticPod(staticPod), "SetUp error: staticPod")
    
    	status := getRandomPodStatus()
    	now := metav1.Now()
    	status.StartTime = &now
    	m.SetPodStatus(staticPod, status)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	return cStatus.ExitCode == 0
    }
    
    func isInPlacePodVerticalScalingAllowed(pod *v1.Pod) bool {
    	if !utilfeature.DefaultFeatureGate.Enabled(features.InPlacePodVerticalScaling) {
    		return false
    	}
    	if types.IsStaticPod(pod) {
    		return false
    	}
    	return true
    }
    
    func (m *kubeGenericRuntimeManager) computePodResizeAction(pod *v1.Pod, containerIdx int, kubeContainerStatus *kubecontainer.Status, changes *podActions) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  4. pkg/kubelet/pod_workers_test.go

    	}
    
    	podWorkers, _, processed := createPodWorkers()
    	var channels WorkChannel
    	podWorkers.workerChannelFn = channels.Intercept
    
    	testPod := newNamedPod("2-static", "test1", "pod1", true)
    	if !kubetypes.IsStaticPod(testPod) {
    		t.Fatalf("unable to test static pod")
    	}
    
    	// start two pods with the same name, one static, one apiserver
    	podWorkers.UpdatePod(UpdatePodOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
Back to top