Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for PodInfo (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kube/inject/testdata/inject/proxy-override-runas.yaml.injected

            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 May 14 17:59:39 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/queue/scheduling_queue.go

    	p.addNominatedPodUnlocked(logger, pInfo.PodInfo, nil)
    	return true
    }
    
    // isPodBackingoff returns true if a pod is still waiting for its backoff timer.
    // If this returns true, the pod should not be re-tried.
    func (p *PriorityQueue) isPodBackingoff(podInfo *framework.QueuedPodInfo) bool {
    	if podInfo.Gated {
    		return false
    	}
    	boTime := p.getBackoffTime(podInfo)
    	return boTime.After(p.clock.Now())
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  6. pkg/kube/inject/testdata/inject/proxy-override-runas.yaml.tproxy.injected

            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 May 14 17:59:39 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. pkg/kube/inject/testdata/inject/proxy-override-runas.yaml.cni.injected

            sidecar.istio.io/status: '{"initContainers":["istio-validation"],"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"}'
            traffic.sidecar.istio.io/excludeInboundPorts: "15020"
            traffic.sidecar.istio.io/includeInboundPorts: '*'
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    					t.Errorf("Test %s failed: %v", tc.name, err)
    				}
    			}
    		})
    	}
    }
    
    func TestCleanOrphanVolumes(t *testing.T) {
    	type podInfo struct {
    		podName         string
    		podUID          string
    		outerVolumeName string
    		innerVolumeName string
    	}
    	defaultPodInfo := podInfo{
    		podName:         "pod1",
    		podUID:          "pod1uid",
    		outerVolumeName: "volume-name",
    		innerVolumeName: "volume-name",
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  9. pkg/api/pod/util_test.go

    			expectPolicyInPod:            false,
    		},
    	}
    	for _, podInfo := range podInfos {
    		t.Run(podInfo.description, func(t *testing.T) {
    			oldPod := podInfo.pod()
    			newPod := oldPod.DeepCopy()
    			if oldPod == nil && podInfo.newPodHasFSGroupChangePolicy {
    				newPod = fsGroupPod()
    			}
    
    			if oldPod != nil {
    				if podInfo.newPodHasFSGroupChangePolicy {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  10. pilot/pkg/config/kube/gateway/testdata/deployment/waypoint-no-network-label.yaml

            - mountPath: /etc/istio/proxy
              name: istio-envoy
            - mountPath: /var/run/secrets/tokens
              name: istio-token
            - mountPath: /etc/istio/pod
              name: istio-podinfo
          serviceAccountName: namespace
          terminationGracePeriodSeconds: 2
          volumes:
          - emptyDir: {}
            name: workload-socket
          - emptyDir:
              medium: Memory
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 22:41:03 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top