- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for NewSet (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)