Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 111 for containerStates (0.19 sec)

  1. pkg/kubelet/metrics/collectors/resource_metrics.go

    		metrics.NewLazyConstMetric(nodeSwapUsageDesc, metrics.GaugeValue, float64(*s.Swap.SwapUsageBytes)))
    }
    
    func (rc *resourceMetricsCollector) collectContainerStartTime(ch chan<- metrics.Metric, pod summary.PodStats, s summary.ContainerStats) {
    	if s.StartTime.Unix() <= 0 {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 07:13:37 UTC 2023
    - 9.2K bytes
    - Viewed (2)
  2. pkg/api/v1/pod/util.go

    // It returns true if "name" exists, else returns false.
    func GetContainerStatus(statuses []v1.ContainerStatus, name string) (v1.ContainerStatus, bool) {
    	for i := range statuses {
    		if statuses[i].Name == name {
    			return statuses[i], true
    		}
    	}
    	return v1.ContainerStatus{}, false
    }
    
    // GetExistingContainerStatus extracts the status of container "name" from "statuses",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 17:18:04 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  3. pkg/controller/job/indexed_job_utils_test.go

    								},
    							},
    						},
    					},
    				},
    			},
    			pod: buildPod().indexFailureCount("0").status(v1.PodStatus{
    				Phase: v1.PodFailed,
    				ContainerStatuses: []v1.ContainerStatus{
    					{
    						State: v1.ContainerState{
    							Terminated: &v1.ContainerStateTerminated{
    								ExitCode: 3,
    							},
    						},
    					},
    				},
    			}).index("0").trackingFinalizer().Pod,
    			wantResult: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    // If the pod UID changes, we will not be able to find the containerStatus to compare against.
    func containerChanged(container *v1.Container, containerStatus *kubecontainer.Status) (uint64, uint64, bool) {
    	expectedHash := kubecontainer.HashContainer(container)
    	return expectedHash, containerStatus.Hash, containerStatus.Hash != expectedHash
    }
    
    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/stats/cri_stats_provider.go

    	}
    	return result, nil
    }
    
    func (p *criStatsProvider) makeContainerCPUAndMemoryStats(
    	stats *runtimeapi.ContainerStats,
    	container *runtimeapi.Container,
    ) *statsapi.ContainerStats {
    	result := &statsapi.ContainerStats{
    		Name: stats.Attributes.Metadata.Name,
    		// The StartTime in the summary API is the container creation time.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/kuberuntime_container_test.go

    		createdAt  int64 = 327
    		startedAt  int64 = 999
    		finishedAt int64 = 1278
    	)
    
    	for desc, test := range map[string]struct {
    		input    *runtimeapi.ContainerStatus
    		expected *kubecontainer.Status
    	}{
    		"created container": {
    			input: &runtimeapi.ContainerStatus{
    				Id:        cid.ID,
    				Metadata:  meta,
    				Image:     imageSpec,
    				State:     runtimeapi.ContainerState_CONTAINER_CREATED,
    				CreatedAt: createdAt,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 28K bytes
    - Viewed (0)
  7. pkg/util/pod/pod_test.go

    		},
    		{
    			"additional init container condition",
    			func(input v1.PodStatus) v1.PodStatus {
    				input.InitContainerStatuses = []v1.ContainerStatus{
    					{
    						Name:  "init-container",
    						Ready: true,
    					},
    				}
    				return input
    			},
    			false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 15:22:29 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  8. pkg/kubelet/server/stats/summary_sys_containers.go

    	"k8s.io/kubernetes/pkg/kubelet/cm"
    )
    
    func (sp *summaryProviderImpl) GetSystemContainersStats(nodeConfig cm.NodeConfig, podStats []statsapi.PodStats, updateStats bool) (stats []statsapi.ContainerStats) {
    	systemContainers := map[string]struct {
    		name             string
    		forceStatsUpdate bool
    		startTime        metav1.Time
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  9. pkg/apis/core/validation/validation_test.go

    	containerTypes := map[string]func(podStatus *core.PodStatus, containerStatus []core.ContainerStatus){
    		"container": func(podStatus *core.PodStatus, containerStatus []core.ContainerStatus) {
    			podStatus.ContainerStatuses = containerStatus
    		},
    		"initContainer": func(podStatus *core.PodStatus, containerStatus []core.ContainerStatus) {
    			podStatus.InitContainerStatuses = containerStatus
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
  10. pkg/kubelet/prober/prober_manager.go

    			worker.stop()
    		}
    	}
    }
    
    func (m *manager) isContainerStarted(pod *v1.Pod, containerStatus *v1.ContainerStatus) bool {
    	if containerStatus.State.Running == nil {
    		return false
    	}
    
    	if result, ok := m.startupManager.Get(kubecontainer.ParseContainerID(containerStatus.ContainerID)); ok {
    		return result == results.Success
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 11K bytes
    - Viewed (0)
Back to top