Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for decodeInt8 (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top