Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 801 for pfds (0.27 sec)

  1. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			podInformer := informerFactory.Core().V1().Pods().Informer()
    			podInformer.GetStore().Add(test.pod)
    			for i := range test.pods {
    				podInformer.GetStore().Add(test.pods[i])
    			}
    
    			deletedPodNames := sets.New[string]()
    			patchedPodNames := sets.New[string]()
    			client.PrependReactor("patch", "pods", func(action clienttesting.Action) (bool, runtime.Object, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  2. pkg/kubeapiserver/admission/exclusion/resources.go

    // in either include or excluded list.
    var included = []schema.GroupResource{
    	{Group: "", Resource: "bindings"},
    	{Group: "", Resource: "pods/attach"},
    	{Group: "", Resource: "pods/binding"},
    	{Group: "", Resource: "pods/eviction"},
    	{Group: "", Resource: "pods/exec"},
    	{Group: "", Resource: "pods/portforward"},
    
    	// ref: https://github.com/kubernetes/kubernetes/issues/122205#issuecomment-1927390823
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 23:31:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/cache/desired_state_of_world.go

    func getPodsFromMap(podMap map[types.UniquePodName]pod) []*v1.Pod {
    	pods := make([]*v1.Pod, 0, len(podMap))
    	for _, pod := range podMap {
    		pods = append(pods, pod.podObj)
    	}
    	return pods
    }
    
    func (dsw *desiredStateOfWorld) GetPodToAdd() map[types.UniquePodName]PodToAdd {
    	dsw.RLock()
    	defer dsw.RUnlock()
    
    	pods := make(map[types.UniquePodName]PodToAdd)
    	for nodeName, nodeObj := range dsw.nodesManaged {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/autoscaling/v1/generated.proto

      // resource metric across all relevant pods, represented as a percentage of
      // the requested value of the resource for the pods.
      // +optional
      optional int32 targetAverageUtilization = 2;
    
      // targetAverageValue is the target value of the average of the
      // resource metric across all relevant pods, as a raw value (instead of as
      // a percentage of the request), similar to the "pods" metric source type.
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 22K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/autoscaling/v1/generated.proto

      // resource metric across all relevant pods, represented as a percentage of
      // the requested value of the resource for the pods.
      // +optional
      optional int32 targetAverageUtilization = 2;
    
      // targetAverageValue is the target value of the average of the
      // resource metric across all relevant pods, as a raw value (instead of as
      // a percentage of the request), similar to the "pods" metric source type.
      // +optional
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/autoscaling/v1/types.go

    	// pods refers to a metric describing each pod in the current scale target
    	// (for example, transactions-processed-per-second).  The values will be
    	// averaged together before being compared to the target value.
    	// +optional
    	Pods *PodsMetricSource `json:"pods,omitempty" protobuf:"bytes,3,opt,name=pods"`
    
    	// resource refers to a resource metric (such as those specified in
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. pkg/kubelet/apis/podresources/server_v1alpha1_test.go

    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	for _, tc := range []struct {
    		desc             string
    		pods             []*v1.Pod
    		devices          []*podresourcesv1.ContainerDevices
    		expectedResponse *v1alpha1.ListPodResourcesResponse
    	}{
    		{
    			desc:             "no pods",
    			pods:             []*v1.Pod{},
    			devices:          []*podresourcesv1.ContainerDevices{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_getters_test.go

    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodVolumeDeviceDir("abc123", "plugin")
    	exp = filepath.Join(root, "pods/abc123/volumeDevices/plugin")
    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodPluginsDir("abc123")
    	exp = filepath.Join(root, "pods/abc123/plugins")
    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodPluginDir("abc123", "foobar")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. pkg/controller/volume/ephemeral/controller_test.go

    			podKey: podKey(testPodWithEphemeral),
    		},
    		{
    			name: "pod-deleted",
    			pods: func() []*v1.Pod {
    				deleted := metav1.Now()
    				pods := []*v1.Pod{testPodWithEphemeral.DeepCopy()}
    				pods[0].DeletionTimestamp = &deleted
    				return pods
    			}(),
    			podKey: podKey(testPodWithEphemeral),
    		},
    		{
    			name:   "no-volumes",
    			pods:   []*v1.Pod{testPod},
    			podKey: podKey(testPod),
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/queue/scheduling_queue.go

    }
    
    // NominatedPodsForNode returns a copy of pods that are nominated to run on the given node,
    // but they are waiting for other pods to be removed from the node.
    func (npm *nominator) NominatedPodsForNode(nodeName string) []*framework.PodInfo {
    	npm.lock.RLock()
    	defer npm.lock.RUnlock()
    	// Make a copy of the nominated Pods so the caller can mutate safely.
    	pods := make([]*framework.PodInfo, len(npm.nominatedPods[nodeName]))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top