Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 232 for podB (0.03 sec)

  1. hack/testdata/pod.yaml

    apiVersion: v1
    kind: Pod
    metadata:
      name: test-pod
      labels:
        name: test-pod-label
    spec:
      containers:
      - name: kubernetes-pause
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 07:02:51 UTC 2024
    - 172 bytes
    - Viewed (0)
  2. src/internal/coverage/pods/pods.go

    		}
    		for _, e := range p.elements {
    			pod.CounterDataFiles = append(pod.CounterDataFiles, e.file)
    			pod.Origins = append(pod.Origins, e.origin)
    			pod.ProcessIDs = append(pod.ProcessIDs, e.pid)
    		}
    		pods = append(pods, pod)
    	}
    	slices.SortFunc(pods, func(a, b Pod) int {
    		return strings.Compare(a.MetaFile, b.MetaFile)
    	})
    	return pods
    }
    
    func warning(s string, a ...interface{}) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    // or are known to be fully terminated. This method should only be used
    // when the set of pods being filtered is upstream of the pod worker, i.e.
    // the pods the pod manager is aware of.
    func (kl *Kubelet) filterOutInactivePods(pods []*v1.Pod) []*v1.Pod {
    	filteredPods := make([]*v1.Pod, 0, len(pods))
    	for _, p := range pods {
    		// if a pod is fully terminated by UID, it should be excluded from the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/manager_test.go

    	})
    	pod2 := makePod(v1.ResourceList{
    		v1.ResourceName(res2.resourceName): res2.resourceQuantity,
    	})
    
    	activePods := []*v1.Pod{pod1, pod2}
    	podsStub.updateActivePods(activePods)
    
    	err = testManager.Allocate(pod1, &pod1.Spec.Containers[0])
    	as.Nil(err)
    	err = testManager.Allocate(pod2, &pod2.Spec.Containers[0])
    	as.Nil(err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/interface.go

    	// to a map of currently waiting pods and return status with "Wait" code.
    	// Pod will remain waiting pod for the minimum duration returned by the Permit plugins.
    	RunPermitPlugins(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status
    
    	// WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  6. pkg/kubelet/secret/secret_manager.go

    }
    
    func (s *secretManager) RegisterPod(pod *v1.Pod) {
    	s.manager.RegisterPod(pod)
    }
    
    func (s *secretManager) UnregisterPod(pod *v1.Pod) {
    	s.manager.UnregisterPod(pod)
    }
    
    func getSecretNames(pod *v1.Pod) sets.Set[string] {
    	result := sets.New[string]()
    	podutil.VisitPodSecretNames(pod, func(name string) bool {
    		result.Insert(name)
    		return true
    	})
    	return result
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/batch/v1/types.go

    // an actual pod condition type.
    type PodFailurePolicyOnPodConditionsPattern struct {
    	// Specifies the required Pod condition type. To match a pod condition
    	// it is required that specified type equals the pod condition type.
    	Type corev1.PodConditionType `json:"type" protobuf:"bytes,1,req,name=type"`
    
    	// Specifies the required Pod condition status. To match a pod condition
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/pod.go

    func (pc *PodCache) getPodByProxy(proxy *model.Proxy) *v1.Pod {
    	var pod *v1.Pod
    	key := podKeyByProxy(proxy)
    	if key.Name != "" {
    		pod = pc.getPodByKey(key)
    		if pod != nil {
    			return pod
    		}
    	}
    
    	// only need to fetch the corresponding pod through the first IP, although there are multiple IP scenarios,
    	// because multiple ips belong to the same pod
    	proxyIP := proxy.IPAddresses[0]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    			patchBytes: []byte(test.patch),
    		}
    		jp := jsonPatcher{patcher: p}
    		codec := codecs.LegacyCodec(examplev1.SchemeGroupVersion)
    		pod := &examplev1.Pod{}
    		pod.Name = "podA"
    		pod.ObjectMeta.Finalizers = []string{"foo"}
    		versionedJS, err := runtime.Encode(codec, pod)
    		if err != nil {
    			t.Errorf("%s: unexpected error: %v", test.name, err)
    			continue
    		}
    		_, _, err = jp.applyJSPatch(versionedJS)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  10. pkg/kubelet/configmap/configmap_manager.go

    }
    
    func (c *configMapManager) RegisterPod(pod *v1.Pod) {
    	c.manager.RegisterPod(pod)
    }
    
    func (c *configMapManager) UnregisterPod(pod *v1.Pod) {
    	c.manager.UnregisterPod(pod)
    }
    
    func getConfigMapNames(pod *v1.Pod) sets.Set[string] {
    	result := sets.New[string]()
    	podutil.VisitPodConfigmapNames(pod, func(name string) bool {
    		result.Insert(name)
    		return true
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top