Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for NamedResourcesFilter (0.38 sec)

  1. pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel_test.go

    	}
    
    }
    
    func TestController(t *testing.T) {
    	filterAny := &resourceapi.NamedResourcesFilter{
    		Selector: "true",
    	}
    	filterNone := &resourceapi.NamedResourcesFilter{
    		Selector: "false",
    	}
    	filterBrokenType := &resourceapi.NamedResourcesFilter{
    		Selector: "1",
    	}
    	filterBrokenEvaluation := &resourceapi.NamedResourcesFilter{
    		Selector: `attributes.bool["no-such-attribute"]`,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  2. pkg/apis/resource/validation/validation_resourceclassparameters_test.go

    						DriverName: goodName,
    						ResourceFilterModel: resource.ResourceFilterModel{
    							NamedResources: &resource.NamedResourcesFilter{Selector: "true"},
    						},
    					},
    					{
    						DriverName: badName,
    						ResourceFilterModel: resource.ResourceFilterModel{
    							NamedResources: &resource.NamedResourcesFilter{Selector: "true"},
    						},
    					},
    				}
    				return parameters
    			}(),
    		},
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:16 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. pkg/apis/resource/v1alpha2/zz_generated.conversion.go

    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*v1alpha2.NamedResourcesFilter)(nil), (*resource.NamedResourcesFilter)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1alpha2_NamedResourcesFilter_To_resource_NamedResourcesFilter(a.(*v1alpha2.NamedResourcesFilter), b.(*resource.NamedResourcesFilter), scope)
    	}); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/resource/v1alpha2/namedresources.go

    	//    attributes.stringslice["b"].isSorted()
    	Selector string `json:"selector" protobuf:"bytes,1,name=selector"`
    }
    
    // NamedResourcesFilter is used in ResourceFilterModel.
    type NamedResourcesFilter struct {
    	// Selector is a CEL expression which must evaluate to true if a
    	// resource instance is suitable. The language is as defined in
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 12:18:45 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. pkg/apis/resource/namedresources.go

    	// For example:
    	//
    	//    attributes.quantity["a"].isGreaterThan(quantity("0")) &&
    	//    attributes.stringslice["b"].isSorted()
    	Selector string
    }
    
    // NamedResourcesFilter is used in ResourceFilterModel.
    type NamedResourcesFilter struct {
    	// Selector is a CEL expression which must evaluate to true if a
    	// resource instance is suitable. The language is as defined in
    	// https://kubernetes.io/docs/reference/using-api/cel/
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 12:18:45 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/resource/v1alpha2/zz_generated.deepcopy.go

    func (in *NamedResourcesFilter) DeepCopyInto(out *NamedResourcesFilter) {
    	*out = *in
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesFilter.
    func (in *NamedResourcesFilter) DeepCopy() *NamedResourcesFilter {
    	if in == nil {
    		return nil
    	}
    	out := new(NamedResourcesFilter)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. pkg/apis/resource/zz_generated.deepcopy.go

    func (in *NamedResourcesFilter) DeepCopyInto(out *NamedResourcesFilter) {
    	*out = *in
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesFilter.
    func (in *NamedResourcesFilter) DeepCopy() *NamedResourcesFilter {
    	if in == nil {
    		return nil
    	}
    	out := new(NamedResourcesFilter)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel.go

    		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 {
    		compilation := cel.Compiler.CompileCELExpression(filter.Selector, environment.StoredExpressions)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:26:16 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. pkg/apis/resource/structured/namedresources/validation/validation.go

    	return validateSelector(opts, request.Selector, fldPath.Child("selector"))
    }
    
    func ValidateFilter(opts Options, filter *resource.NamedResourcesFilter, fldPath *field.Path) field.ErrorList {
    	return validateSelector(opts, filter.Selector, fldPath.Child("selector"))
    }
    
    func validateSelector(opts Options, selector string, fldPath *field.Path) field.ErrorList {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:26:20 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/resource/v1alpha2/generated.pb.go

    func (m *NamedResourcesFilter) Reset()      { *m = NamedResourcesFilter{} }
    func (*NamedResourcesFilter) ProtoMessage() {}
    func (*NamedResourcesFilter) Descriptor() ([]byte, []int) {
    	return fileDescriptor_4312f5b44a31ec02, []int{7}
    }
    func (m *NamedResourcesFilter) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 261.9K bytes
    - Viewed (0)
Back to top