Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 50 for decodeUint (0.17 sec)

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

    	}
    
    	if printManifest {
    		return configMapBytes, nil
    	}
    
    	kubeproxyConfigMap := &v1.ConfigMap{}
    	if err := kuberuntime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), configMapBytes, kubeproxyConfigMap); err != nil {
    		return []byte(""), errors.Wrap(err, "unable to decode kube-proxy configmap")
    	}
    
    	if !kubeProxyCfg.IsUserSupplied() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 13:23:44 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/runtime/doc.go

    //
    // 7. All of your serializations and deserializations are handled in a
    // centralized place.
    //
    // Package runtime provides a conversion helper to make 5 easy, and the
    // Encode/Decode/DecodeInto trio to accomplish 7. You can also register
    // additional "codecs" which use a version of your choice. It's
    // recommended that you register your types with runtime in your
    // package's init function.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 17 18:08:55 UTC 2018
    - 2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/phases/uploadconfig/uploadconfig_test.go

    				if configData == "" {
    					t2.Fatal("Fail to find ClusterConfigurationConfigMapKey key")
    				}
    
    				decodedCfg := &kubeadmapi.ClusterConfiguration{}
    				if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), []byte(configData), decodedCfg); err != nil {
    					t2.Fatalf("unable to decode config from bytes: %v", err)
    				}
    
    				if len(decodedCfg.ComponentConfigs) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 08:46:51 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/plugin/pkg/audit/log/backend_test.go

    			backend.ProcessEvents(event)
    			// decode events back and compare with the original one.
    			result := &auditinternal.Event{}
    			decoder := audit.Codecs.UniversalDecoder(version)
    			if err := runtime.DecodeInto(decoder, buf.Bytes(), result); err != nil {
    				t.Errorf("failed decoding buf: %s, apiVersion: %s", buf.String(), version)
    				continue
    			}
    			if !reflect.DeepEqual(event, result) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 08 06:37:26 UTC 2022
    - 5K bytes
    - Viewed (0)
  5. cluster/gce/gci/configure_helper_test.go

    	json, err := os.ReadFile(c.manifestDestination)
    	if err != nil {
    		c.t.Fatalf("Failed to read manifest: %s, %v", c.manifestDestination, err)
    	}
    
    	if err := runtime.DecodeInto(legacyscheme.Codecs.UniversalDecoder(), json, &c.pod); err != nil {
    		c.t.Fatalf("Failed to decode manifest:\n%s\nerror: %v", json, err)
    	}
    }
    
    func (c *ManifestTestCase) tearDown() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 30 06:23:50 UTC 2021
    - 4.8K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/util/config/joinconfiguration.go

    	}
    
    	if len(joinBytes) == 0 {
    		return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind)
    	}
    
    	internalcfg := &kubeadmapi.JoinConfiguration{}
    	if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), joinBytes, internalcfg); err != nil {
    		return nil, err
    	}
    
    	// Applies dynamic defaults to settings not provided with flags
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/options/tracing.go

    	}
    	internalConfig := &apiserver.TracingConfiguration{}
    	// this handles json/yaml/whatever, and decodes all registered version to the internal version
    	if err := runtime.DecodeInto(codecs.UniversalDecoder(), data, internalConfig); err != nil {
    		return nil, fmt.Errorf("unable to decode tracing configuration data: %v", err)
    	}
    	return &internalConfig.TracingConfiguration, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 21:39:39 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/runtime/codec.go

    // Decode is a convenience wrapper for decoding data into an Object.
    func Decode(d Decoder, data []byte) (Object, error) {
    	obj, _, err := d.Decode(data, nil, nil)
    	return obj, err
    }
    
    // DecodeInto performs a Decode into the provided object.
    func DecodeInto(d Decoder, data []byte, into Object) error {
    	out, gvk, err := d.Decode(data, nil, into)
    	if err != nil {
    		return err
    	}
    	if out != into {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 03:20:30 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/util/config/resetconfiguration.go

    	}
    
    	if len(resetBytes) == 0 {
    		return nil, errors.Errorf("no %s found in the supplied config", constants.JoinConfigurationKind)
    	}
    
    	internalcfg := &kubeadmapi.ResetConfiguration{}
    	if err := runtime.DecodeInto(kubeadmscheme.Codecs.UniversalDecoder(), resetBytes, internalcfg); err != nil {
    		return nil, err
    	}
    
    	// Applies dynamic defaults to settings not provided with flags
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. src/image/jpeg/scan.go

    func (d *decoder) refine(b *block, h *huffman, zigStart, zigEnd, delta int32) error {
    	// Refining a DC component is trivial.
    	if zigStart == 0 {
    		if zigEnd != 0 {
    			panic("unreachable")
    		}
    		bit, err := d.decodeBit()
    		if err != nil {
    			return err
    		}
    		if bit {
    			b[0] |= delta
    		}
    		return nil
    	}
    
    	// Refining AC components is more complicated; see sections G.1.2.2 and G.1.2.3.
    	zig := zigStart
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 25 00:46:29 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top