- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for decodeUint (0.25 sec)
-
cmd/kubeadm/app/util/config/initconfiguration.go
// Decode the bytes into the internal struct. Under the hood, the bytes will be unmarshalled into the // right external version, defaulted, and converted into the internal version. if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), fileContent, initcfg); err != nil { return nil, err } continue } if kubeadmutil.GroupVersionKindsHasClusterConfiguration(gvk) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 17.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/roundtrip.go
obj3 := reflect.New(reflect.TypeOf(object).Elem()).Interface().(runtime.Object) if err := runtime.DecodeInto(codec, data, obj3); err != nil { t.Errorf("%v: %v", name, err) return } // special case for kinds which are internal and external at the same time (many in meta.k8s.io are). For those // runtime.DecodeInto above will return the external variant and set the APIVersion and kind, while the input
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 16.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/scheme_test.go
externalToInternalCalls: 0, } // Register functions to verify that scope.Meta() gets set correctly. utilruntime.Must(conversions.registerConversions(scheme)) t.Run("Encode, Decode, DecodeInto, and DecodeToVersion", func(t *testing.T) { simple := &runtimetesting.InternalSimple{ TestString: "foo", } codecs := serializer.NewCodecFactory(scheme) codec := codecs.LegacyCodec(externalGV)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 38.2K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/cluster.go
kubeadmapiv1.SchemeGroupVersion.WithKind(constants.ClusterConfigurationKind), []byte(clusterConfigurationData)); err != nil { klog.Warning(err.Error()) } if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), []byte(clusterConfigurationData), &initcfg.ClusterConfiguration); err != nil { return nil, errors.Wrap(err, "failed to decode cluster configuration data") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 11K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
klog.Warning(err.Error()) } // As long as we support only component configs with a single kind, this is allowed return runtime.DecodeInto(Codecs.UniversalDecoder(), yaml, into) } return nil } // ensureInitializedComponentConfigs is an utility func to initialize the ComponentConfigMap in ClusterConfiguration prior to possible writes to it
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go
objToUpdate := p.restPatcher.New() if err := runtime.DecodeInto(p.codec, patchedObjJS, objToUpdate); err != nil { strictError, isStrictError := runtime.AsStrictDecodingError(err) switch { case !isStrictError: // disregard any appliedStrictErrs, because it's an incomplete // list of strict errors given that we don't know what fields were // unknown because DecodeInto failed. Non-strict errors trump in this case.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
var decoded *apidiscoveryv2beta1.APIGroupDiscoveryList if len(bytes) > 0 { decoded = &apidiscoveryv2beta1.APIGroupDiscoveryList{} err := runtime.DecodeInto(codecs.UniversalDecoder(), bytes, decoded) if err != nil { panic(fmt.Sprintf("failed to decode response: %v", err)) } } return r, bytes, decoded }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go
if !meta.IsListType(currObj) { items = append(items, currObj) continue } currItems, err := meta.ExtractList(currObj) if err != nil { return err } if errs := runtime.DecodeList(currItems, v.mapper.decoder); len(errs) > 0 { return utilerrors.NewAggregate(errs) } itemsToProcess = append(itemsToProcess, currItems...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 21.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns_test.go
for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { deploymentBytes, _ := kubeadmutil.ParseTemplate(testCase.manifest, testCase.data) deployment := &apps.Deployment{} if err := runtime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), deploymentBytes, deployment); err != nil { t.Errorf("unexpected error: %v", err) } if deployment.Spec.Template.Spec.PriorityClassName != "system-cluster-critical" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 41.7K bytes - Viewed (0) -
pkg/volume/util/util.go
} if len(podDef) == 0 { return nil, fmt.Errorf("file was empty: %s", filePath) } pod := &v1.Pod{} codec := legacyscheme.Codecs.UniversalDecoder() if err := apiruntime.DecodeInto(codec, podDef, pod); err != nil { return nil, fmt.Errorf("failed decoding file: %v", err) } return pod, nil } // CalculateTimeoutForVolume calculates time for a Recycler pod to complete a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0)