Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NewFeatureGate (0.25 sec)

  1. pkg/features/client_adapter_test.go

    */
    
    package features
    
    import (
    	"testing"
    
    	clientfeatures "k8s.io/client-go/features"
    	"k8s.io/component-base/featuregate"
    )
    
    func TestClientAdapterEnabled(t *testing.T) {
    	fg := featuregate.NewFeatureGate()
    	if err := fg.Add(map[featuregate.Feature]featuregate.FeatureSpec{
    		"Foo": {Default: true},
    	}); err != nil {
    		t.Fatal(err)
    	}
    
    	a := &clientAdapter{fg}
    	if !a.Enabled("Foo") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jan 16 17:51:00 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. pkg/features/kube_features_test.go

    		}
    	}
    }
    
    // TestClientFeaturesRegistered tests that all client features are registered.
    func TestClientFeaturesRegistered(t *testing.T) {
    	onlyClientFg := featuregate.NewFeatureGate()
    	if err := clientfeatures.AddFeaturesToExistingFeatureGates(&clientAdapter{onlyClientFg}); err != nil {
    		t.Fatal(err)
    	}
    	registeredFeatures := utilfeature.DefaultFeatureGate.DeepCopy().GetAll()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jan 16 17:51:00 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/features/features_test.go

    	}
    
    	for _, test := range tests {
    		t.Run(test.value, func(t *testing.T) {
    			r, err := NewFeatureGate(&someFeatures, test.value)
    
    			if !test.expectedError && err != nil {
    				t.Errorf("NewFeatureGate failed when not expected: %v", err)
    				return
    			} else if test.expectedError && err == nil {
    				t.Error("NewFeatureGate didn't failed when expected")
    				return
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 20 04:57:22 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/feature/feature_gate.go

    	//   featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.<FeatureName>, <value>)
    	DefaultMutableFeatureGate featuregate.MutableFeatureGate = featuregate.NewFeatureGate()
    
    	// DefaultFeatureGate is a shared global FeatureGate.
    	// Top-level commands/options setup that needs to modify this feature gate should use DefaultMutableFeatureGate.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/features/features.go

    		known = append(known, fmt.Sprintf("%s=true|false (%sdefault=%t)", k, pre, v.Default))
    	}
    	sort.Strings(known)
    	return known
    }
    
    // NewFeatureGate parses a string of the form "key1=value1,key2=value2,..." into a
    // map[string]bool of known keys or returns an error.
    func NewFeatureGate(f *FeatureList, value string) (map[string]bool, error) {
    	featureGate := map[string]bool{}
    	for _, s := range strings.Split(value, ",") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 13:55:11 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/config.go

    	var err error
    
    	cmd := &cobra.Command{
    		Use:   "pull",
    		Short: "Pull images used by kubeadm",
    		RunE: func(_ *cobra.Command, _ []string) error {
    			externalClusterCfg.FeatureGates, err = features.NewFeatureGate(&features.InitFeatureGates, featureGatesString)
    			if err != nil {
    				return err
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/cmd/upgrade/common.go

    	}
    
    	// If features gates are passed to the command line, use it (otherwise use featureGates from configuration)
    	if flags.featureGatesString != "" {
    		initCfg.FeatureGates, err = features.NewFeatureGate(&features.InitFeatureGates, flags.featureGatesString)
    		if err != nil {
    			return nil, nil, nil, nil, errors.Wrap(err, "[upgrade/config] FATAL")
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 08:34:39 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    				newPolicyAccessor,
    				newBindingAccessor,
    				compileFunc,
    				sif,
    				i2,
    				r,
    			)
    			return source
    		}, dispatcher)
    	plugin.SetEnabled(true)
    
    	featureGate := featuregate.NewFeatureGate()
    	err = featureGate.Add(map[featuregate.Feature]featuregate.FeatureSpec{
    		//!TODO: move this to validating specific tests
    		features.ValidatingAdmissionPolicy: {
    			Default: true, PreRelease: featuregate.Beta}})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/cmd/init.go

    	// validated values to the public kubeadm config API when applicable
    	var err error
    	if initOptions.externalClusterCfg.FeatureGates, err = features.NewFeatureGate(&features.InitFeatureGates, initOptions.featureGatesString); err != nil {
    		return nil, err
    	}
    
    	if err = validation.ValidateMixedArguments(cmd.Flags()); err != nil {
    		return nil, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 17 03:37:05 UTC 2024
    - 24.1K bytes
    - Viewed (0)
Back to top