- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 208 for podStates (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)