Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for podschedulingcontexts (0.29 sec)

  1. pkg/controller/resourceclaim/controller.go

    			claim.Status.Allocation == nil {
    			scheduling, err := ec.podSchedulingLister.PodSchedulingContexts(pod.Namespace).Get(pod.Name)
    			if apierrors.IsNotFound(err) {
    				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 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. 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)
  3. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go

    			rbacv1helpers.NewRule(ReadWrite...).Groups(resourceGroup).Resources("podschedulingcontexts").RuleOrDie(),
    			rbacv1helpers.NewRule(Read...).Groups(resourceGroup).Resources("podschedulingcontexts/status").RuleOrDie(),
    			rbacv1helpers.NewRule(ReadUpdate...).Groups(legacyGroup).Resources("pods/finalizers").RuleOrDie(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. pkg/scheduler/eventhandlers.go

    			}
    			handlers = append(handlers, handlerRegistration)
    		case framework.PodSchedulingContext:
    			if utilfeature.DefaultFeatureGate.Enabled(features.DynamicResourceAllocation) {
    				if handlerRegistration, err = informerFactory.Resource().V1alpha2().PodSchedulingContexts().Informer().AddEventHandler(
    					buildEvtResHandler(at, framework.PodSchedulingContext, "PodSchedulingContext"),
    				); err != nil {
    					return err
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  5. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go

    				rbacv1helpers.NewRule("get", "list", "watch", "create", "update", "patch").Groups(resourceGroup).Resources("podschedulingcontexts").RuleOrDie(),
    				rbacv1helpers.NewRule("update", "patch").Groups(resourceGroup).Resources("resourceclaims", "resourceclaims/status").RuleOrDie(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  6. cmd/kube-controller-manager/app/core.go

    		klog.FromContext(ctx),
    		controllerContext.ClientBuilder.ClientOrDie("resource-claim-controller"),
    		controllerContext.InformerFactory.Core().V1().Pods(),
    		controllerContext.InformerFactory.Resource().V1alpha2().PodSchedulingContexts(),
    		controllerContext.InformerFactory.Resource().V1alpha2().ResourceClaims(),
    		controllerContext.InformerFactory.Resource().V1alpha2().ResourceClaimTemplates())
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 39K bytes
    - Viewed (0)
  7. pkg/apis/resource/validation/validation_podschedulingcontext_test.go

    	scenarios := map[string]struct {
    		oldScheduling *resource.PodSchedulingContext
    		update        func(schedulingCtx *resource.PodSchedulingContext) *resource.PodSchedulingContext
    		wantFailures  field.ErrorList
    	}{
    		"valid-no-op-update": {
    			oldScheduling: validScheduling,
    			update: func(schedulingCtx *resource.PodSchedulingContext) *resource.PodSchedulingContext {
    				return schedulingCtx
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 09:18:08 UTC 2023
    - 13.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/resource/v1alpha2/zz_generated.deepcopy.go

    func (in *PodSchedulingContext) DeepCopyInto(out *PodSchedulingContext) {
    	*out = *in
    	out.TypeMeta = in.TypeMeta
    	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
    	in.Spec.DeepCopyInto(&out.Spec)
    	in.Status.DeepCopyInto(&out.Status)
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSchedulingContext.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/resource/v1alpha2/generated.proto

      // +optional
      optional bool shareable = 3;
    }
    
    // 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: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  10. 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)
Back to top