Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NewSet (0.18 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go

    func (strategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"apiextensions.k8s.io/v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    		"apiextensions.k8s.io/v1beta1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of a CustomResourceDefinition before creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. pkg/registry/core/service/strategy.go

    // and should not be modified by the user.
    func (svcStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate sets contextual defaults and clears fields that are not allowed to be set by end users on creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:36 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. pkg/registry/batch/job/strategy.go

    // and should not be modified by the user.
    func (jobStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"batch/v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of a job before creation.
    func (jobStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/discovery/token/token.go

    	token, err := bootstraptokenv1.NewBootstrapTokenString(cfg.BootstrapToken.Token)
    	if err != nil {
    		return nil, err
    	}
    
    	// Load the CACertHashes into a pubkeypin.Set
    	pubKeyPins := pubkeypin.NewSet()
    	if err = pubKeyPins.Allow(cfg.BootstrapToken.CACertHashes...); err != nil {
    		return nil, errors.Wrap(err, "invalid discovery token CA certificate hash")
    	}
    
    	// Make sure the interval is not bigger than the duration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. pkg/apis/resource/validation/validation.go

    			// but not added.
    			if resourceClaim.DeletionTimestamp != nil || resourceClaim.Status.DeallocationRequested {
    				oldSet := sets.New(oldClaim.Status.ReservedFor...)
    				newSet := sets.New(resourceClaim.Status.ReservedFor...)
    				newItems := newSet.Difference(oldSet)
    				if len(newItems) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 09:18:10 UTC 2024
    - 28.3K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_node_status.go

    		newCMAAnnotation, newSet = node.Annotations[volutil.ControllerManagedAttachAnnotation]
    	)
    
    	if newCMAAnnotation == existingCMAAnnotation {
    		return false
    	}
    
    	// If the just-constructed node and the existing node do
    	// not have the same value, update the existing node with
    	// the correct value of the annotation.
    	if !newSet {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  7. pkg/test/framework/testcontext.go

    	}
    	return tmp
    }
    
    func (c *testContext) newChildContext(test *testImpl) *testContext {
    	return newTestContext(test, test.goTest, c.suite, c.scope, label.NewSet(test.labels...))
    }
    
    func (c *testContext) NewSubTest(name string) Test {
    	if c.test == nil {
    		panic(fmt.Sprintf("Attempting to create subtest %s from a TestContext with no associated Test", name))
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  8. pkg/registry/core/pod/strategy.go

    // and should not be modified by the user.
    func (podStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears fields that are not allowed to be set by end users on creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/strategy.go

    	fields := map[fieldpath.APIVersion]*fieldpath.Set{}
    
    	if a.status != nil {
    		fields[fieldpath.APIVersion(a.kind.GroupVersion().String())] = fieldpath.NewSet(
    			fieldpath.MakePathOrDie("status"),
    		)
    	}
    
    	return fields
    }
    
    // PrepareForCreate clears the status of a CustomResource before creation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 21:22:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  10. pkg/test/framework/suite.go

    	s := &suiteImpl{
    		testID:      testID,
    		mRun:        fn,
    		osExit:      osExit,
    		getSettings: getSettingsFn,
    		labels:      label.NewSet(),
    	}
    
    	return s
    }
    
    func (s *suiteImpl) EnvironmentFactory(fn resource.EnvironmentFactory) Suite {
    	if fn != nil && s.envFactory != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top