- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 194 for PodInfo (0.46 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/plugins/queuesort/priority_sort_test.go
p1: &framework.QueuedPodInfo{ PodInfo: mustNewPodInfo(t, st.MakePod().Priority(lowPriority).Obj()), }, p2: &framework.QueuedPodInfo{ PodInfo: mustNewPodInfo(t, st.MakePod().Priority(highPriority).Obj()), }, expected: false, // p2 should be ahead of p1 in the queue }, { name: "p1.priority greater than p2.priority", p1: &framework.QueuedPodInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 12 14:11:04 UTC 2022 - 2.8K 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/internal/queue/scheduling_queue_test.go
prepareFunc: func(t *testing.T, logger klog.Logger, q *PriorityQueue) (oldPod, newPod *v1.Pod) { podInfo := q.newQueuedPodInfo(medPriorityPodInfo.Pod) if err := q.podBackoffQ.Add(podInfo); err != nil { t.Errorf("adding pod to backoff queue error: %v", err) } return podInfo.Pod, podInfo.Pod }, schedulingHintsEnablement: []bool{false, true}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K 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) -
cni/pkg/plugin/kubernetes.go
pod, err := client.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return nil, err } pi := ExtractPodInfo(pod) log.Debugf("Pod %v/%v info: \n%+v", podNamespace, podName, pi) return pi, nil } func ExtractPodInfo(pod *v1.Pod) *PodInfo { pi := &PodInfo{ Containers: sets.New[string](),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 3.6K 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 (1) -
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)