Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for prioritylevelconfiguration (0.29 sec)

  1. pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go

    		return copy
    	}()
    
    	tests := []struct {
    		name      string
    		strategy  func() EnsureStrategy[*flowcontrolv1.PriorityLevelConfiguration]
    		current   *flowcontrolv1.PriorityLevelConfiguration
    		bootstrap *flowcontrolv1.PriorityLevelConfiguration
    		expected  *flowcontrolv1.PriorityLevelConfiguration
    	}{
    		// for suggested configurations
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

    }
    
    func genPLs(rng *rand.Rand, trial string, oldPLNames sets.String, n int) (pls []*flowcontrol.PriorityLevelConfiguration, plMap map[string]*flowcontrol.PriorityLevelConfiguration, goodNames, badNames sets.String) {
    	pls = make([]*flowcontrol.PriorityLevelConfiguration, 0, n)
    	plMap = make(map[string]*flowcontrol.PriorityLevelConfiguration, n)
    	goodNames = sets.NewString()
    	badNames = sets.NewString(trial+"-nopl1", trial+"-nopl2")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    			pl := obj.(*flowcontrol.PriorityLevelConfiguration)
    			klog.V(7).Infof("Triggered API priority and fairness config reloading in %s due to creation of PLC %s", cfgCtlr.name, pl.Name)
    			cfgCtlr.configQueue.Add(0)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			newPL := newObj.(*flowcontrol.PriorityLevelConfiguration)
    			oldPL := oldObj.(*flowcontrol.PriorityLevelConfiguration)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/flowcontrol/v1/zz_generated.deepcopy.go

    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PriorityLevelConfiguration.
    func (in *PriorityLevelConfiguration) DeepCopy() *PriorityLevelConfiguration {
    	if in == nil {
    		return nil
    	}
    	out := new(PriorityLevelConfiguration)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:41 UTC 2023
    - 17.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap/default.go

    					[]string{flowcontrol.NonResourceAll}),
    			},
    		},
    	)
    )
    
    func newPriorityLevelConfiguration(name string, spec flowcontrol.PriorityLevelConfigurationSpec) *flowcontrol.PriorityLevelConfiguration {
    	return &flowcontrol.PriorityLevelConfiguration{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    			Annotations: map[string]string{
    				flowcontrol.AutoUpdateAnnotationKey: "true",
    			},
    		},
    		Spec: spec,
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/flowcontrol/v1beta1/types.go

    type FlowSchemaSpec struct {
    	// `priorityLevelConfiguration` should reference a PriorityLevelConfiguration in the cluster. If the reference cannot
    	// be resolved, the FlowSchema will be ignored and marked as invalid in its status.
    	// Required.
    	PriorityLevelConfiguration PriorityLevelConfigurationReference `json:"priorityLevelConfiguration" protobuf:"bytes,1,opt,name=priorityLevelConfiguration"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:27:57 UTC 2023
    - 31.2K bytes
    - Viewed (0)
  7. pkg/registry/flowcontrol/rest/storage_flowcontrol.go

    	plcOps := ensurer.NewPriorityLevelConfigurationOps(clientset.PriorityLevelConfigurations(), plcLister)
    	if err := ensurer.EnsureConfigurations(ctx, plcOps, flowcontrolbootstrap.SuggestedPriorityLevelConfigurations, ensurer.NewSuggestedEnsureStrategy[*flowcontrolv1.PriorityLevelConfiguration]()); err != nil {
    		return err
    	}
    
    	fsOps := ensurer.NewFlowSchemaOps(clientset.FlowSchemas(), fsLister)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  8. pkg/api/testing/defaulting_test.go

    		{Group: "flowcontrol.apiserver.k8s.io", Version: "v1alpha1", Kind: "PriorityLevelConfiguration"}:           {},
    		{Group: "flowcontrol.apiserver.k8s.io", Version: "v1alpha1", Kind: "PriorityLevelConfigurationList"}:       {},
    		{Group: "flowcontrol.apiserver.k8s.io", Version: "v1beta1", Kind: "PriorityLevelConfiguration"}:            {},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  9. pkg/apis/flowcontrol/validation/validation.go

    		}
    	}
    	if len(spec.PriorityLevelConfiguration.Name) > 0 {
    		for _, msg := range ValidatePriorityLevelConfigurationName(spec.PriorityLevelConfiguration.Name, false) {
    			allErrs = append(allErrs, field.Invalid(fldPath.Child("priorityLevelConfiguration").Child("name"), spec.PriorityLevelConfiguration.Name, msg))
    		}
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 26.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/flowcontrol/v1beta2/types.go

    type FlowSchemaSpec struct {
    	// `priorityLevelConfiguration` should reference a PriorityLevelConfiguration in the cluster. If the reference cannot
    	// be resolved, the FlowSchema will be ignored and marked as invalid in its status.
    	// Required.
    	PriorityLevelConfiguration PriorityLevelConfigurationReference `json:"priorityLevelConfiguration" protobuf:"bytes,1,opt,name=priorityLevelConfiguration"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:27:57 UTC 2023
    - 31.2K bytes
    - Viewed (0)
Back to top