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