- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 111 for containerStates (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/util/pod/pod_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 15:22:29 UTC 2022 - 4.5K bytes - Viewed (0) -
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) -
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) -
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)