- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for PodInfo (0.4 sec)
-
pkg/scheduler/framework/plugins/interpodaffinity/filtering.go
// No need to deep copy the podInfo because it shouldn't change. copy.podInfo = s.podInfo copy.namespaceLabels = s.namespaceLabels return © } // updateWithPod updates the preFilterState counters with the (anti)affinity matches for the given podInfo. func (s *preFilterState) updateWithPod(pInfo *framework.PodInfo, node *v1.Node, multiplier int64) { if s == nil { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 10:24:54 UTC 2023 - 14.6K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
// Consider using this instead of AddPod if a PodInfo is already computed. func (n *NodeInfo) AddPodInfo(podInfo *PodInfo) { n.Pods = append(n.Pods, podInfo) if podWithAffinity(podInfo.Pod) { n.PodsWithAffinity = append(n.PodsWithAffinity, podInfo) } if podWithRequiredAntiAffinity(podInfo.Pod) { n.PodsWithRequiredAntiAffinity = append(n.PodsWithRequiredAntiAffinity, podInfo) } n.update(podInfo.Pod, 1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/scoring.go
} if state.podInfo, err = framework.NewPodInfo(pod); err != nil { // Ideally we never reach here, because errors will be caught by PreFilter return framework.AsStatus(fmt.Errorf("failed to parse pod: %w", err)) } for i := range state.podInfo.PreferredAffinityTerms { if err := pl.mergeAffinityTermNamespacesIfNotEmpty(&state.podInfo.PreferredAffinityTerms[i].AffinityTerm); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot_test.go
}, expectedNodesInfos: []*framework.NodeInfo{ { Pods: []*framework.PodInfo{ {Pod: podsWithPVCs[0]}, }, }, { Pods: []*framework.PodInfo{ {Pod: podsWithPVCs[1]}, }, }, { Pods: []*framework.PodInfo{ {Pod: podsWithPVCs[2]}, }, }, }, expectedNumNodes: 3,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/list.yaml.injected
prometheus.io/scrape: "true" sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: app: hello security.istio.io/tlsMode: istio
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go
conflictingPVCRefCount int } func (s *preFilterState) updateWithPod(podInfo *framework.PodInfo, multiplier int) { s.conflictingPVCRefCount += multiplier * s.conflictingPVCRefCountForPod(podInfo) } func (s *preFilterState) conflictingPVCRefCountForPod(podInfo *framework.PodInfo) int { conflicts := 0 for _, volume := range podInfo.Pod.Spec.Volumes { if volume.PersistentVolumeClaim == nil { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
func (sched *Scheduler) ScheduleOne(ctx context.Context) { logger := klog.FromContext(ctx) podInfo, err := sched.NextPod(logger) if err != nil { logger.Error(err, "Error while retrieving next pod from scheduling queue") return } // pod could be nil when schedulerQueue is closed if podInfo == nil || podInfo.Pod == nil { return } pod := podInfo.Pod // TODO(knelasevero): Remove duplicated keys from log entry calls
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/hello-multi.yaml.injected
prometheus.io/scrape: "true" sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: app: hello security.istio.io/tlsMode: istio
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
func filterPodsWithPDBViolation(podInfos []*framework.PodInfo, pdbs []*policy.PodDisruptionBudget) (violatingPodInfos, nonViolatingPodInfos []*framework.PodInfo) { pdbsAllowed := make([]int32, len(pdbs)) for i, pdb := range pdbs { pdbsAllowed[i] = pdb.Status.DisruptionsAllowed } for _, podInfo := range podInfos { pod := podInfo.Pod pdbForPodIsViolated := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider.go
// Lookup the pod-level cgroup's CPU and memory stats podInfo := getCadvisorPodInfoFromPodUID(podUID, allInfos) if podInfo != nil { cpu, memory := cadvisorInfoToCPUandMemoryStats(podInfo) podStats.CPU = cpu podStats.Memory = memory podStats.Swap = cadvisorInfoToSwapStats(podInfo) podStats.ProcessStats = cadvisorInfoToProcessStats(podInfo) } status, found := p.statusProvider.GetPodStatus(podUID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 16 13:34:22 UTC 2023 - 18.9K bytes - Viewed (0)