Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ManagedResources (0.23 sec)

  1. pkg/scheduler/extender.go

    	if err != nil {
    		return nil, err
    	}
    	client := &http.Client{
    		Transport: transport,
    		Timeout:   config.HTTPTimeout.Duration,
    	}
    	managedResources := sets.New[string]()
    	for _, r := range config.ManagedResources {
    		managedResources.Insert(string(r.Name))
    	}
    	return &HTTPExtender{
    		extenderURL:      config.URLPrefix,
    		preemptVerb:      config.PreemptVerb,
    		filterVerb:       config.FilterVerb,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. pkg/scheduler/apis/config/validation/validation_test.go

    			},
    		},
    		PluginConfig: []config.PluginConfig{{
    			Name: "CustomSort",
    		}},
    	}}
    
    	extenderDuplicateManagedResource := validConfig.DeepCopy()
    	extenderDuplicateManagedResource.Extenders[0].ManagedResources = []config.ExtenderManagedResource{
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    	}
    
    	extenderDuplicateBind := validConfig.DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  3. pkg/scheduler/extender_test.go

    func TestIsInterested(t *testing.T) {
    	mem := &HTTPExtender{
    		managedResources: sets.New[string](),
    	}
    	mem.managedResources.Insert("memory")
    
    	for _, tc := range []struct {
    		label    string
    		extender *HTTPExtender
    		pod      *v1.Pod
    		want     bool
    	}{
    		{
    			label: "Empty managed resources",
    			extender: &HTTPExtender{
    				managedResources: sets.New[string](),
    			},
    			pod:  &v1.Pod{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. pkg/scheduler/apis/config/validation/validation.go

    				extender.Weight, "must have a positive weight applied to it"))
    		}
    		if extender.BindVerb != "" {
    			binders++
    		}
    		for j, resource := range extender.ManagedResources {
    			managedResourcesPath := path.Child("managedResources").Index(j)
    			validationErrors := validateExtendedResourceName(managedResourcesPath.Child("name"), v1.ResourceName(resource.Name))
    			errs = append(errs, validationErrors...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. pkg/scheduler/apis/config/zz_generated.deepcopy.go

    	if in.TLSConfig != nil {
    		in, out := &in.TLSConfig, &out.TLSConfig
    		*out = new(ExtenderTLSConfig)
    		(*in).DeepCopyInto(*out)
    	}
    	out.HTTPTimeout = in.HTTPTimeout
    	if in.ManagedResources != nil {
    		in, out := &in.ManagedResources, &out.ManagedResources
    		*out = make([]ExtenderManagedResource, len(*in))
    		copy(*out, *in)
    	}
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 22:02:57 UTC 2022
    - 16.2K bytes
    - Viewed (0)
  6. pkg/scheduler/apis/config/v1/zz_generated.conversion.go

    	out.TLSConfig = (*config.ExtenderTLSConfig)(unsafe.Pointer(in.TLSConfig))
    	out.HTTPTimeout = in.HTTPTimeout
    	out.NodeCacheCapable = in.NodeCacheCapable
    	out.ManagedResources = *(*[]config.ExtenderManagedResource)(unsafe.Pointer(&in.ManagedResources))
    	out.Ignorable = in.Ignorable
    	return nil
    }
    
    // Convert_v1_Extender_To_config_Extender is an autogenerated conversion function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  7. pkg/scheduler/apis/config/types.go

    	// so the scheduler should only send minimal information about the eligible nodes
    	// assuming that the extender already cached full details of all nodes in the cluster
    	NodeCacheCapable bool
    	// ManagedResources is a list of extended resources that are managed by
    	// this extender.
    	// - A pod will be sent to the extender on the Filter, Prioritize and Bind
    	//   (if the extender is the binder) phases iff the pod requests at least
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  8. pkg/scheduler/scheduler.go

    		}
    		if !extender.IsIgnorable() {
    			fExtenders = append(fExtenders, extender)
    		} else {
    			ignorableExtenders = append(ignorableExtenders, extender)
    		}
    		for _, r := range extenders[i].ManagedResources {
    			if r.IgnoredByScheduler {
    				ignoredExtendedResources = append(ignoredExtendedResources, r.Name)
    			}
    		}
    	}
    	// place ignorable extenders to the tail of extenders
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  9. pkg/generated/openapi/zz_generated.openapi.go

    							Format:      "",
    						},
    					},
    					"managedResources": {
    						VendorExtensible: spec.VendorExtensible{
    							Extensions: spec.Extensions{
    								"x-kubernetes-list-type": "atomic",
    							},
    						},
    						SchemaProps: spec.SchemaProps{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 3M bytes
    - Viewed (0)
Back to top