- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 190 for podStates (0.14 sec)
-
pkg/scheduler/internal/cache/cache.go
// This mutex guards all fields within this cache struct. mu sync.RWMutex // a set of assumed pod keys. // The key could further be used to get an entry in podStates. assumedPods sets.Set[string] // a map from pod key to podState. podStates map[string]*podState nodes map[string]*nodeInfoListItem // headNode points to the most recently updated NodeInfo in "nodes". It is the // head of the linked list.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/podstatus.go
ResourceClaimStatuses []PodResourceClaimStatusApplyConfiguration `json:"resourceClaimStatuses,omitempty"` } // PodStatusApplyConfiguration constructs an declarative configuration of the PodStatus type for use with // apply. func PodStatus() *PodStatusApplyConfiguration { return &PodStatusApplyConfiguration{} } // WithPhase sets the Phase field in the declarative configuration to the given value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:43:16 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker_test.go
podState.firstStartedPulling.Add(time.Second*10), podState.firstStartedPulling) } if !podState.lastFinishedPulling.Equal(frozenTime.Add(time.Second * 20)) { // should be updated when the pod's last image finished pulling t.Errorf("expected pod lastFinishedPulling: %s but got lastFinishedPulling: %s", podState.lastFinishedPulling.Add(time.Second*20), podState.lastFinishedPulling) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
podStats = newPodMemoryStats(pod, *resource.NewQuantity(limits.StorageEphemeral().Value()*2, resource.BinarySI)) default: podStats = newPodMemoryStats(pod, resource.MustParse(memoryWorkingSet)) } return pod, podStats } func makePIDStats(nodeAvailablePIDs string, numberOfRunningProcesses string, podStats map[*v1.Pod]statsapi.PodStats) *statsapi.Summary { val := resource.MustParse(nodeAvailablePIDs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
} // cachedStatsFunc returns a statsFunc based on the provided pod stats. func cachedStatsFunc(podStats []statsapi.PodStats) statsFunc { uid2PodStats := map[string]statsapi.PodStats{} for i := range podStats { uid2PodStats[podStats[i].PodRef.UID] = podStats[i] } return func(pod *v1.Pod) (statsapi.PodStats, bool) { stats, found := uid2PodStats[string(pod.UID)] return stats, found } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
for _, pod := range pods { podStats, ok := statsFunc(pod) if !ok { continue } if m.emptyDirLimitEviction(podStats, pod) { evicted = append(evicted, pod) continue } if m.podEphemeralStorageLimitEviction(podStats, pod) { evicted = append(evicted, pod) continue } if m.containerEphemeralStorageLimitEviction(podStats, pod) { evicted = append(evicted, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kubelet/pleg/evented_test.go
kubelet_running_pods 5 ` testMetric(t, expectedMetric, metrics.RunningPodCount.FQName()) // stop sandbox containers for first 2 pods for _, podStatus := range podStatuses[:2] { podId := string(podStatus.ID) newPodStatus := kubecontainer.PodStatus{ ID: podStatus.ID, SandboxStatuses: []*v1.PodSandboxStatus{ {Id: podId}, }, ContainerStatuses: []*kubecontainer.Status{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 01 07:45:05 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/util/pod/pod_test.go
description string mutate func(input v1.PodStatus) v1.PodStatus expectUnchanged bool expectedPatchBytes []byte }{ { "no change", func(input v1.PodStatus) v1.PodStatus { return input }, true, []byte(fmt.Sprintf(`{"metadata":{"uid":"myuid"}}`)), }, { "message change", func(input v1.PodStatus) v1.PodStatus { input.Message = "random message" return input },
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/apis/core/v1/conversion_test.go
t.Errorf("%v: Convert core.PodStatus to v1.PodStatus failed. Expected v1.PodStatus[%v]=%v but found %v", i, idx, input.PodIPs[idx].IP, v1PodStatus.PodIPs[idx].IP) } } } } func Test_v1_PodStatus_to_core_PodStatus(t *testing.T) { asymmetricInputs := []struct { name string in v1.PodStatus out core.PodStatus }{ { name: "mismatched podIP", in: v1.PodStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 05:34:15 UTC 2023 - 21.7K bytes - Viewed (0)