Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for PodSchedulingContext (0.56 sec)

  1. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	// Deleted? That can happen because we ourselves delete the PodSchedulingContext while
    	// working on the pod. This can be ignored.
    	if oldObj != nil && newObj == nil {
    		logger.V(4).Info("PodSchedulingContext got deleted")
    		return framework.QueueSkip, nil
    	}
    
    	oldPodScheduling, newPodScheduling, err := schedutil.As[*resourcev1alpha2.PodSchedulingContext](oldObj, newObj)
    	if err != nil {
    		// Shouldn't happen.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    						scheduling: func(in *resourcev1alpha2.PodSchedulingContext) *resourcev1alpha2.PodSchedulingContext {
    							return st.FromPodSchedulingContexts(in).
    								SelectedNode(workerNode.Name).
    								Obj()
    						},
    					},
    				},
    			},
    		},
    		"delayed-allocation-scheduling-finish-concurrent-label-update": {
    			// Use the populated PodSchedulingContext object to select a
    			// node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  3. pkg/controller/resourceclaim/controller.go

    				return true, "need to create PodSchedulingContext for scheduled pod"
    			}
    			if err != nil {
    				// Shouldn't happen.
    				return true, fmt.Sprintf("internal error while checking for PodSchedulingContext: %v", err)
    			}
    			if scheduling.Spec.SelectedNode != pod.Spec.NodeName {
    				// Need to update PodSchedulingContext.
    				return true, "need to updated PodSchedulingContext for scheduled pod"
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. pkg/controller/resourceclaim/controller_test.go

    			Name:              pod.Spec.ResourceClaims[0].Name,
    			ResourceClaimName: &generatedTestClaim.Name,
    		})
    		return pod
    	}()
    
    	podSchedulingContext = resourcev1alpha2.PodSchedulingContext{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      testPodName,
    			Namespace: testNamespace,
    			OwnerReferences: []metav1.OwnerReference{
    				{
    					APIVersion: "v1",
    					Kind:       "Pod",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 08:56:16 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  5. pkg/apis/resource/validation/validation.go

    		allErrs = append(allErrs, field.TooLongMaxLength(fldPath, len(consumers), maxSize))
    	}
    	return allErrs
    }
    
    // ValidatePodSchedulingContext validates a PodSchedulingContext.
    func ValidatePodSchedulingContexts(schedulingCtx *resource.PodSchedulingContext) field.ErrorList {
    	allErrs := corevalidation.ValidateObjectMeta(&schedulingCtx.ObjectMeta, true, corevalidation.ValidatePodName, field.NewPath("metadata"))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 09:18:10 UTC 2024
    - 28.3K bytes
    - Viewed (0)
  6. pkg/scheduler/testing/wrappers.go

    }
    
    // PodSchedulingWrapper wraps a PodSchedulingContext inside.
    type PodSchedulingWrapper struct {
    	resourcev1alpha2.PodSchedulingContext
    }
    
    // MakePodSchedulingContexts creates a PodSchedulingContext wrapper.
    func MakePodSchedulingContexts() *PodSchedulingWrapper {
    	return &PodSchedulingWrapper{resourcev1alpha2.PodSchedulingContext{}}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 42.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/resource/v1alpha2/generated.proto

      //
      // +listType=atomic
      repeated string strings = 1;
    }
    
    // PodSchedulingContext objects hold information that is needed to schedule
    // a Pod with ResourceClaims that use "WaitForFirstConsumer" allocation
    // mode.
    //
    // This is an alpha type and requires enabling the DynamicResourceAllocation
    // feature gate.
    message PodSchedulingContext {
      // Standard object metadata
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 22:07:50 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  8. api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_openapi.json

              }
            },
            "required": [
              "strings"
            ],
            "type": "object"
          },
          "io.k8s.api.resource.v1alpha2.PodSchedulingContext": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 12:18:45 UTC 2024
    - 656.6K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/types.go

    	CSIDriver               GVK = "storage.k8s.io/CSIDriver"
    	CSIStorageCapacity      GVK = "storage.k8s.io/CSIStorageCapacity"
    	StorageClass            GVK = "storage.k8s.io/StorageClass"
    	PodSchedulingContext    GVK = "PodSchedulingContext"
    	ResourceClaim           GVK = "ResourceClaim"
    	ResourceClass           GVK = "ResourceClass"
    	ResourceClaimParameters GVK = "ResourceClaimParameters"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  10. pkg/scheduler/scheduler_test.go

    				},
    				{Resource: framework.PersistentVolumeClaim, ActionType: framework.All}: {
    					{PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn},
    				},
    				{Resource: framework.PodSchedulingContext, ActionType: framework.All}: {
    					{PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn},
    				},
    				{Resource: framework.ResourceClaim, ActionType: framework.All}: {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
Back to top