- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 62 for NewSet (0.61 sec)
-
pkg/monitoring/gauge.go
// If a metric really requires `metric{} 0`, they can explicitly call .Record(0). if f.currentGaugeSet == nil { f.currentGaugeSet = &gaugeValues{} f.attributeSets[attribute.NewSet()] = f.currentGaugeSet } f.currentGaugeSet.val = value f.attributeSetsMutex.Unlock() } func (f *gauge) With(labelValues ...LabelValue) Metric { attrs, set := rebuildAttributes(f.baseMetric, labelValues)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/registry/apps/daemonset/strategy.go
// and should not be modified by the user. func (daemonSetStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set { fields := map[fieldpath.APIVersion]*fieldpath.Set{ "apps/v1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), } return fields } // PrepareForCreate clears the status of a daemon set before creation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 01:52:02 UTC 2022 - 8.7K bytes - Viewed (0) -
pkg/registry/apps/replicaset/strategy.go
// and should not be modified by the user. func (rsStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set { fields := map[fieldpath.APIVersion]*fieldpath.Set{ "apps/v1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), } return fields } // PrepareForCreate clears the status of a ReplicaSet before creation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 16 21:06:43 UTC 2022 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/status_strategy.go
func (a statusStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set { fields := map[fieldpath.APIVersion]*fieldpath.Set{ fieldpath.APIVersion(a.customResourceStrategy.kind.GroupVersion().String()): fieldpath.NewSet( // Note that if there are other top level fields unique to CRDs, // those will also get removed by the apiserver prior to persisting, // but won't be added to the resetFields set.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 22:16:10 UTC 2023 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/admission_test.go
wrap := &mockAdmissionController{} ac := fieldmanager.NewManagedFieldsValidatingAdmissionController(wrap) now := metav1.Now() validFieldsV1 := metav1.FieldsV1{} var err error validFieldsV1.Raw, err = fieldpath.NewSet(fieldpath.MakePathOrDie("metadata", "labels", "test-label")).ToJSON() if err != nil { t.Fatal(err) } validManagedFieldsEntry := metav1.ManagedFieldsEntry{ APIVersion: "v1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 12 21:32:54 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/strategy.go
// and should not be modified by the user. func (rcStrategy) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set { fields := map[fieldpath.APIVersion]*fieldpath.Set{ "v1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), } return fields } // PrepareForCreate clears the status of a replication controller before creation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 16 21:06:10 UTC 2022 - 9.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedmanager.go
Difference(comparison.Removed) return lastAppliedObjFieldSet, nil } // TODO: replace with merge.Conflicts.ToSet() func conflictsToSet(conflicts merge.Conflicts) *fieldpath.Set { conflictSet := fieldpath.NewSet() for _, conflict := range []merge.Conflict(conflicts) { conflictSet.Insert(conflict.Path) } return conflictSet } func conflictsDifference(conflicts merge.Conflicts, s *fieldpath.Set) merge.Conflicts {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 5.9K 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)