Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 457 for unmarshalV1 (0.28 sec)

  1. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time_test.go

    	}
    
    	for _, c := range cases {
    		var result MicroTimeHolder
    		if err := yaml.Unmarshal([]byte(c.input), &result); err != nil {
    			t.Errorf("Failed to unmarshal input '%v': %v", c.input, err)
    		}
    		if result.T != c.result {
    			t.Errorf("Failed to unmarshal input '%v': expected %+v, got %+v", c.input, c.result, result)
    		}
    	}
    }
    
    func TestMicroTimeMarshalJSON(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/networkfilter_test.go

    	}
    	if config, ok := redisFilter.ConfigType.(*listener.Filter_TypedConfig); ok {
    		redisProxy := redis.RedisProxy{}
    		if err := config.TypedConfig.UnmarshalTo(&redisProxy); err != nil {
    			t.Errorf("unmarshal failed: %v", err)
    		}
    		if redisProxy.StatPrefix != "redis" {
    			t.Errorf("redis proxy statPrefix is %s", redisProxy.StatPrefix)
    		}
    		if !redisProxy.LatencyInMicros {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. operator/pkg/manifest/shared.go

    func overlaySetFlagValues(iopYAML string, setFlags []string) (string, error) {
    	iop := make(map[string]any)
    	if err := yaml.Unmarshal([]byte(iopYAML), &iop); err != nil {
    		return "", err
    	}
    	// Unmarshal returns nil for empty manifests but we need something to insert into.
    	if iop == nil {
    		iop = make(map[string]any)
    	}
    
    	for _, sf := range setFlags {
    		p, v := getPV(sf)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 03 06:27:07 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/internal/modes/roundtrip_test.go

    				if err != nil {
    					t.Fatalf("unexpected error from Marshal of original: %v", err)
    				}
    
    				var iface interface{}
    				if err := modePair.dec.Unmarshal(cborFromOriginal, &iface); err != nil {
    					t.Fatalf("unexpected error from Unmarshal into %T: %v", &iface, err)
    				}
    
    				cborFromIface, err := modePair.enc.Marshal(iface)
    				if err != nil {
    					t.Fatalf("unexpected error from Marshal of iface: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 21:48:12 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time_test.go

    	}
    
    	for _, c := range cases {
    		var result TimeHolder
    		if err := yaml.Unmarshal([]byte(c.input), &result); err != nil {
    			t.Errorf("Failed to unmarshal input '%v': %v", c.input, err)
    		}
    		if result.T != c.result {
    			t.Errorf("Failed to unmarshal input '%v': expected %+v, got %+v", c.input, c.result, result)
    		}
    	}
    }
    
    func TestTimeMarshalJSON(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:09 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. pkg/test/framework/components/echo/config.go

    			configs[i].Namespace = namespace.Static(fmt.Sprint(ns))
    			delete(raw, "Namespace")
    		}
    	}
    
    	// unmarshal again after Namespace stripped is stripped, to avoid unmarshal error
    	modifiedBytes, err := json.Marshal(raw)
    	if err != nil {
    		return nil, err
    	}
    	if err := json.Unmarshal(modifiedBytes, &configs); err != nil {
    		return nil, nil
    	}
    
    	return configs, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. pkg/istio-agent/grpcxds/grpc_bootstrap.go

    }
    
    func (cp *CertificateProvider) UnmarshalJSON(data []byte) error {
    	var dat map[string]*json.RawMessage
    	if err := json.Unmarshal(data, &dat); err != nil {
    		return err
    	}
    	*cp = CertificateProvider{}
    
    	if pluginNameVal, ok := dat["plugin_name"]; ok {
    		if err := json.Unmarshal(*pluginNameVal, &cp.PluginName); err != nil {
    			log.Warnf("failed parsing plugin_name in certificate_provider: %v", err)
    		}
    	} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 00:31:03 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/autoscaling/v2/generated.pb.go

    func (*ContainerResourceMetricSource) Descriptor() ([]byte, []int) {
    	return fileDescriptor_4d5f2c8767749221, []int{0}
    }
    func (m *ContainerResourceMetricSource) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *ContainerResourceMetricSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    	n, err := m.MarshalToSizedBuffer(b)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 162.9K bytes
    - Viewed (0)
  9. pkg/model/proxy_test.go

    			}
    			if string(j) != tt.out {
    				t.Errorf("Got json '%s', expected '%s'", string(j), tt.out)
    			}
    			var meta model.BootstrapNodeMetadata
    			if err := json.Unmarshal(j, &meta); err != nil {
    				t.Fatalf("failed to unmarshal: %v", err)
    			}
    
    			assert.Equal(t, (*meshconfig.ProxyConfig)(meta.NodeMetadata.ProxyConfig), (*meshconfig.ProxyConfig)(tt.inOut.NodeMetadata.ProxyConfig))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 20:38:02 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/networking/v1/generated.pb.go

    func (*HTTPIngressPath) ProtoMessage() {}
    func (*HTTPIngressPath) Descriptor() ([]byte, []int) {
    	return fileDescriptor_2c41434372fec1d7, []int{0}
    }
    func (m *HTTPIngressPath) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *HTTPIngressPath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    	n, err := m.MarshalToSizedBuffer(b)
    	if err != nil {
    		return nil, err
    	}
    	return b[:n], nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 158.2K bytes
    - Viewed (0)
Back to top