Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newClaimController (0.25 sec)

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

    				namedresourcesmodel.AddAllocation(&resource.NamedResources, result.NamedResources)
    			}
    		}
    	}
    
    	return model, nil
    }
    
    func newClaimController(logger klog.Logger, class *resourcev1alpha2.ResourceClass, classParameters *resourcev1alpha2.ResourceClassParameters, claimParameters *resourcev1alpha2.ResourceClaimParameters) (*claimController, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 22 09:03:22 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel.go

    	if result == nil {
    		return
    	}
    	for i := range m.Instances {
    		if m.Instances[i].Instance.Name == result.Name {
    			m.Instances[i].Allocated = true
    			break
    		}
    	}
    }
    
    func NewClaimController(filter *resourceapi.NamedResourcesFilter, requests []*resourceapi.NamedResourcesRequest) (*Controller, error) {
    	c := &Controller{}
    	if filter != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:26:16 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel_test.go

    			expectAllocation: []string{instance2},
    		},
    	}
    
    	for name, tc := range testcases {
    		t.Run(name, func(t *testing.T) {
    			tCtx := ktesting.Init(t)
    
    			controller, createErr := NewClaimController(tc.filter, tc.requests)
    			if createErr != nil {
    				if !tc.expectCreateErr {
    					tCtx.Fatalf("unexpected create error: %v", createErr)
    				}
    				return
    			}
    			if tc.expectCreateErr {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go

    					}(),
    				},
    			},
    		},
    	}
    
    	for name, tc := range testcases {
    		t.Run(name, func(t *testing.T) {
    			tCtx := ktesting.Init(t)
    
    			controller, err := newClaimController(tCtx.Logger(), tc.class, tc.classParameters, tc.claimParameters)
    			if err != nil {
    				if !tc.expectCreateErr {
    					tCtx.Fatalf("unexpected error: %v", err)
    				}
    				return
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    				classParameters, claimParameters, status := pl.lookupParameters(logger, class, claim)
    				if status != nil {
    					return nil, status
    				}
    				controller, err := newClaimController(logger, class, classParameters, claimParameters)
    				if err != nil {
    					return nil, statusError(logger, err)
    				}
    				s.informationsForClaim[index].controller = controller
    				needResourceInformation = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
Back to top