Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 45 of 45 for decodeInt8 (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    	defer response.Body.Close()
    	body, err := ioutil.ReadAll(response.Body)
    	if err != nil {
    		return string(body), err
    	}
    	return string(body), runtime.DecodeInto(decoder, body, object)
    }
    
    func extractBodyObject(response *http.Response, decoder runtime.Decoder) (runtime.Object, string, error) {
    	defer response.Body.Close()
    	body, err := ioutil.ReadAll(response.Body)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:15:22 UTC 2023
    - 158.7K bytes
    - Viewed (0)
Back to top