Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for NewSet (0.25 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedmanager_test.go

          labels:
            app: my-new-label # allowed: update-label
        spec:
          containers:
          - name: my-c
            image: my-image-new # NOT allowed: update image
    `),
    			expectConflictSet: fieldpath.NewSet(
    				fieldpath.MakePathOrDie("metadata", "labels", "app"),
    				fieldpath.MakePathOrDie("spec", "replicas"),
    				fieldpath.MakePathOrDie("spec", "template", "spec", "containers", fieldpath.KeyByFields("name", "my-c"), "image"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 20K bytes
    - Viewed (0)
  2. pkg/registry/certificates/certificates/strategy.go

    func (csrStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set {
    	fields := map[fieldpath.APIVersion]*fieldpath.Set{
    		"certificates.k8s.io/v1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("spec"),
    			fieldpath.MakePathOrDie("status"),
    		),
    		"certificates.k8s.io/v1beta1": fieldpath.NewSet(
    			fieldpath.MakePathOrDie("spec"),
    			fieldpath.MakePathOrDie("status"),
    		),
    	}
    
    	return fields
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 21:41:43 UTC 2022
    - 11.4K bytes
    - Viewed (0)
  3. 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)
  4. guava/src/com/google/common/eventbus/SubscriberRegistry.java

          if (eventSubscribers == null) {
            CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>();
            eventSubscribers =
                MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet);
          }
    
          eventSubscribers.addAll(eventMethodsInListener);
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 10.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

          if (eventSubscribers == null) {
            CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>();
            eventSubscribers =
                MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet);
          }
    
          eventSubscribers.addAll(eventMethodsInListener);
        }
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 10.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/capmanagers_test.go

    		"",
    		func(m internal.Manager) internal.Manager {
    			return internal.NewCapManagersManager(m, 3)
    		})
    
    	set := func(fields ...string) *metav1.FieldsV1 {
    		s := fieldpath.NewSet()
    		for _, f := range fields {
    			s.Insert(fieldpath.MakePathOrDie(f))
    		}
    		b, err := s.ToJSON()
    		if err != nil {
    			panic(fmt.Sprintf("error building ManagedFieldsEntry for test: %v", err))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top