Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for decodeInt8 (0.14 sec)

  1. cmd/kubeadm/app/phases/addons/dns/dns.go

    	return nil
    }
    
    func createCoreDNSAddon(deploymentBytes, serviceBytes, configBytes []byte, client clientset.Interface) error {
    	coreDNSConfigMap := &v1.ConfigMap{}
    	if err := kuberuntime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), configBytes, coreDNSConfigMap); err != nil {
    		return errors.Wrapf(err, "%s ConfigMap", unableToDecodeCoreDNS)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 10:21:20 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. 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)
  3. pkg/scheduler/framework/runtime/framework_test.go

    	var inj injectedResult
    	if err := DecodeInto(injArgs, &inj); err != nil {
    		return nil, err
    	}
    	return &TestScoreWithNormalizePlugin{scoreWithNormalizePlugin1, inj}, nil
    }
    
    func newScoreWithNormalizePlugin2(_ context.Context, injArgs runtime.Object, f framework.Handle) (framework.Plugin, error) {
    	var inj injectedResult
    	if err := DecodeInto(injArgs, &inj); err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. pkg/scheduler/schedule_one_test.go

    	}
    	return nil
    }
    
    func newFakeNodeSelector(_ context.Context, args runtime.Object, _ framework.Handle) (framework.Plugin, error) {
    	pl := &fakeNodeSelector{}
    	if err := frameworkruntime.DecodeInto(args, &pl.fakeNodeSelectorArgs); err != nil {
    		return nil, err
    	}
    	return pl, nil
    }
    
    const (
    	fakeSpecifiedNodeNameAnnotation = "fake-specified-node-name"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top