Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 208 for podStates (0.15 sec)

  1. pkg/kubelet/prober/testing/fake_manager.go

    // Start simulates start syncing the probe status
    func (FakeManager) Start() {}
    
    // UpdatePodStatus simulates updating the Pod Status.
    func (FakeManager) UpdatePodStatus(_ *v1.Pod, podStatus *v1.PodStatus) {
    	for i := range podStatus.ContainerStatuses {
    		podStatus.ContainerStatuses[i].Ready = true
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName0)).Return(v1.PodStatus{StartTime: &p0Time}, true)
    	mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName1)).Return(v1.PodStatus{StartTime: &p1Time}, true)
    	mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName2)).Return(v1.PodStatus{StartTime: &p2Time}, true)
    	mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName3)).Return(v1.PodStatus{StartTime: &p3Time}, true)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. pkg/kubelet/metrics/collectors/log_metrics_test.go

    func TestNoMetricsCollected(t *testing.T) {
    	// Refresh Desc to share with different registry
    	descLogSize = descLogSize.GetRawDesc()
    
    	collector := &logMetricsCollector{
    		podStats: func(_ context.Context) ([]statsapi.PodStats, error) {
    			return []statsapi.PodStats{}, nil
    		},
    	}
    
    	if err := testutil.CustomCollectAndCompare(collector, strings.NewReader(""), ""); err != nil {
    		t.Fatal(err)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  4. pkg/controller/job/pod_failure_policy.go

    func matchOnExitCodes(podStatus *v1.PodStatus, requirement *batch.PodFailurePolicyOnExitCodesRequirement) *v1.ContainerStatus {
    	if containerStatus := getMatchingContainerFromList(podStatus.ContainerStatuses, requirement); containerStatus != nil {
    		return containerStatus
    	}
    	return getMatchingContainerFromList(podStatus.InitContainerStatuses, requirement)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 20:44:11 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cri_stats_provider_others.go

    }
    
    func addCRIPodCPUStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    }
    
    func addCRIPodProcessStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  6. pkg/kubelet/server/stats/summary_sys_containers_windows.go

    func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
    	stats = append(stats, sp.getSystemPodsCPUAndMemoryStats(nodeConfig, podStats, updateStats))
    	return stats
    }
    
    func (sp *summaryProviderImpl) GetSystemContainersCPUAndMemoryStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3K bytes
    - Viewed (0)
  7. pkg/kubelet/server/stats/summary_windows_test.go

    	assert.Equal(summary.Node.SystemContainers[0].CPU.UsageCoreNanoSeconds, podStats[0].CPU.UsageCoreNanoSeconds)
    	assert.Equal(summary.Node.SystemContainers[0].CPU.UsageNanoCores, podStats[0].CPU.UsageNanoCores)
    	assert.Equal(summary.Node.SystemContainers[0].Memory.WorkingSetBytes, podStats[0].Memory.WorkingSetBytes)
    	assert.Equal(summary.Node.SystemContainers[0].Memory.UsageBytes, podStats[0].Memory.UsageBytes)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. pkg/api/v1/pod/util_test.go

    		LastTransitionTime: metav1.NewTime(time.Add(1000)),
    	}
    
    	tests := []struct {
    		desc              string
    		podStatus         v1.PodStatus
    		expectedCondition *v1.PodCondition
    	}{
    		{
    			desc: "containers ready condition exists",
    			podStatus: v1.PodStatus{
    				Conditions: []v1.PodCondition{containersReadyCondition},
    			},
    			expectedCondition: &containersReadyCondition,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 32.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_pods_test.go

    				pod.Status.PodIP = pod.Status.PodIPs[0].IP
    			}
    
    			// set old status
    			podStatus := &kubecontainer.PodStatus{
    				ID:        pod.UID,
    				Name:      pod.Name,
    				Namespace: pod.Namespace,
    			}
    			podStatus.IPs = tc.nodeIPs
    
    			status := kl.generateAPIPodStatus(pod, podStatus, false)
    			if !reflect.DeepEqual(status.PodIPs, tc.expectedPodIPs) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  10. pkg/kubelet/container/testing/fake_cache.go

    }
    
    func (c *fakeCache) Get(id types.UID) (*container.PodStatus, error) {
    	return c.runtime.GetPodStatus(context.Background(), id, "", "")
    }
    
    func (c *fakeCache) GetNewerThan(id types.UID, minTime time.Time) (*container.PodStatus, error) {
    	return c.Get(id)
    }
    
    func (c *fakeCache) Set(id types.UID, status *container.PodStatus, err error, timestamp time.Time) (updated bool) {
    	return true
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 14:36:16 UTC 2022
    - 1.3K bytes
    - Viewed (0)
Back to top