- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 77 for newPoset (0.15 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) -
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) -
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/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/proxy/ipvs/ipset_test.go
expectedEntries: []string{"FE80::0202:B3FF:FE1E:8329,sctp:80"}, }, } for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { set := NewIPSet(fakeipset.NewFake(testIPSetVersion), testCase.set.Name, testCase.setType, testCase.ipv6, "comment-"+testCase.set.Name) if err := set.handle.CreateSet(&set.IPSet, true); err != nil { t.Errorf("Unexpected error: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.5K 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) -
cni/pkg/nodeagent/server.go
// // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil { return probeSet, err } probeSet.Flush() return probeSet, nil } func (s *Server) Start() { log.Info("CNI ambient server starting")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K 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)