- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 208 for podStates (0.12 sec)
-
cni/pkg/nodeagent/informers_test.go
defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
podStatus.IPs = append(podStatus.IPs, ipInfo.IP) } if len(podStatus.IPs) == 0 && len(apiPodStatus.PodIP) > 0 { podStatus.IPs = []string{apiPodStatus.PodIP} } // If the pod is terminal, we don't need to continue to setup the pod if apiPodStatus.Phase == v1.PodSucceeded || apiPodStatus.Phase == v1.PodFailed { kl.statusManager.SetPodStatus(pod, apiPodStatus) isTerminal = true return isTerminal, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (1) -
pkg/kubelet/active_deadline.go
return false } // get the latest status to determine if it was started podStatus, ok := m.podStatusProvider.GetPodStatus(pod.UID) if !ok { podStatus = pod.Status } // we have no start time so just return if podStatus.StartTime.IsZero() { return false } // determine if the deadline was exceeded start := podStatus.StartTime.Time duration := m.clock.Since(start)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
newFailedPods := []*v1.Pod{} for _, finishTime := range tc.newSucceededPods { newSucceededPods = append(newSucceededPods, &v1.Pod{ ObjectMeta: metav1.ObjectMeta{}, Status: v1.PodStatus{ Phase: v1.PodSucceeded, ContainerStatuses: []v1.ContainerStatus{ { State: v1.ContainerState{ Terminated: &v1.ContainerStateTerminated{ FinishedAt: finishTime,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
} for _, pod := range pods { podStats, found := statsFunc(pod) if !found { t.Errorf("Pod stats were not found for pod %v", pod.UID) } if *podStats.Memory.WorkingSetBytes != podWorkingSetBytes { t.Errorf("Pod working set expected %v, actual: %v", podWorkingSetBytes, *podStats.Memory.WorkingSetBytes) } } } func TestThresholdsMet(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
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/kubelet/status/fake_status_manager.go
} func (m *fakeManager) Start() { klog.InfoS("Start()") return } func (m *fakeManager) GetPodStatus(uid types.UID) (v1.PodStatus, bool) { klog.InfoS("GetPodStatus()") return v1.PodStatus{}, false } func (m *fakeManager) SetPodStatus(pod *v1.Pod, status v1.PodStatus) { klog.InfoS("SetPodStatus()") return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kube/krt/index_test.go
}) } SimplePods.Register(TrackerHandler[SimplePod](tt)) pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.4"}, } pc.CreateOrUpdateStatus(pod) tt.WaitUnordered("add/namespace/name") assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}}) pod.Status.PodIP = "1.2.3.5"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/kubelet/container/cache_test.go
} func getTestPodIDAndStatus(numContainers int) (types.UID, *PodStatus) { id := types.UID(strconv.FormatInt(time.Now().UnixNano(), 10)) name := fmt.Sprintf("cache-foo-%s", string(id)) namespace := "ns" var status *PodStatus if numContainers > 0 { status = &PodStatus{ID: id, Name: name, Namespace: namespace} } else { status = &PodStatus{ID: id} } for i := 0; i < numContainers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 24 20:23:12 UTC 2020 - 6K bytes - Viewed (0)