- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for decodeInt8 (0.39 sec)
-
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) -
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/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/apimachinery/pkg/test/apis_meta_v1_unstructed_unstructure_test.go
} }`) pod := &testapigroup.Carp{} _, codecs := TestScheme() codec := apitesting.TestCodec(codecs, schema.GroupVersion{Group: "", Version: runtime.APIVersionInternal}) err := runtime.DecodeInto(codec, originalJSON, pod) if err != nil { t.Fatalf("unexpected error: %v", err) } // Round-trip with unstructured codec
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 17.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) -
src/encoding/gob/codec_test.go
} func verifyInt(i int64, t *testing.T) { defer testError(t) var b = new(encBuffer) encState := newEncoderState(b) encState.encodeInt(i) decState := newDecodeState(newDecBuffer(b.Bytes())) j := decState.decodeInt() if i != j { t.Errorf("Encode/Decode: sent %#x received %#x", uint64(i), uint64(j)) } } // Test basic encode/decode routines for signed integers func TestIntCodec(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Aug 19 23:03:14 UTC 2023 - 36.9K bytes - Viewed (0)