Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for unmarshaler (0.15 sec)

  1. cmd/data-usage-cache_gen.go

    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z dataUsageHash) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendString(o, string(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *dataUsageHash) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 string
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 100.8K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen.go

    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 0
    	_ = z
    	o = append(o, 0x80)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BaseOptions) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 130.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.pb.go

    func (*ExemptPriorityLevelConfiguration) Descriptor() ([]byte, []int) {
    	return fileDescriptor_2e620af2eea53237, []int{0}
    }
    func (m *ExemptPriorityLevelConfiguration) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *ExemptPriorityLevelConfiguration) 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
    - 142K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/batch/v1/generated.pb.go

    func (*CronJob) ProtoMessage() {}
    func (*CronJob) Descriptor() ([]byte, []int) {
    	return fileDescriptor_79228dc2c4001a22, []int{0}
    }
    func (m *CronJob) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *CronJob) 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: Thu Mar 07 20:49:09 UTC 2024
    - 133K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/cluster_builder_test.go

    	t.Helper()
    	if c.TransportSocket == nil {
    		return nil
    	}
    	tlsContext := &tls.UpstreamTlsContext{}
    	err := c.TransportSocket.GetTypedConfig().UnmarshalTo(tlsContext)
    	if err != nil {
    		t.Fatalf("Failed to unmarshall tls context: %v", err)
    	}
    	return tlsContext
    }
    
    func TestShouldH2Upgrade(t *testing.T) {
    	tests := []struct {
    		name           string
    		clusterName    string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  6. src/crypto/x509/x509_test.go

    		t.Errorf("Marshal(rsa.PublicKey) = %x, want %x", derBytes2, derBytes)
    	}
    	pub3 := new(rsa.PublicKey)
    	rest, err := asn1.Unmarshal(derBytes, pub3)
    	if err != nil {
    		t.Errorf("Unmarshal(rsa.PublicKey): %v", err)
    	}
    	if len(rest) != 0 || pub.N.Cmp(pub3.N) != 0 || pub.E != pub3.E {
    		t.Errorf("Unmarshal(rsa.PublicKey) = %+v, %q want %+v, %q", pub, rest, pub2, []byte(nil))
    	}
    
    	publicKeys := []struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:00:16 UTC 2024
    - 163.4K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_test.go

    					anyOptions := cluster.TypedExtensionProtocolOptions[v3.HttpProtocolOptionsType]
    					g.Expect(anyOptions).NotTo(BeNil())
    					httpProtocolOptions := &http.HttpProtocolOptions{}
    					anyOptions.UnmarshalTo(httpProtocolOptions)
    					g.Expect(httpProtocolOptions.CommonHttpProtocolOptions.MaxRequestsPerConnection.GetValue()).
    						To(Equal(uint32(expected.Http.MaxRequestsPerConnection)))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/garbagecollector_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	patched, err := strategicpatch.StrategicMergePatch(originalData, p, v1.Pod{})
    	if err != nil {
    		t.Fatal(err)
    	}
    	var got v1.Pod
    	if err := json.Unmarshal(patched, &got); err != nil {
    		t.Fatal(err)
    	}
    	if !reflect.DeepEqual(expected, got) {
    		t.Errorf("expected: %#v,\ngot: %#v", expected, got)
    	}
    }
    
    func TestUnblockOwnerReference(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  9. api/openapi-spec/v3/apis__apiregistration.k8s.io__v1_openapi.json

    JSON will look something like this:\n\n\t{\n\t\t\"kind\":\"MyAPIObject\",\n\t\t\"apiVersion\":\"v1\",\n\t\t\"myPlugin\": {\n\t\t\t\"kind\":\"PluginA\",\n\t\t\t\"aOption\":\"foo\",\n\t\t},\n\t}\n\nSo what happens? Decode first uses json or yaml to unmarshal the serialized data into your external MyAPIObject. That causes the raw JSON to be stored, but not unpacked. The next step is to copy (using pkg/conversion) into the internal struct. The runtime package's DefaultScheme has conversion functions installed...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 135.1K bytes
    - Viewed (0)
  10. api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json

    JSON will look something like this:\n\n\t{\n\t\t\"kind\":\"MyAPIObject\",\n\t\t\"apiVersion\":\"v1\",\n\t\t\"myPlugin\": {\n\t\t\t\"kind\":\"PluginA\",\n\t\t\t\"aOption\":\"foo\",\n\t\t},\n\t}\n\nSo what happens? Decode first uses json or yaml to unmarshal the serialized data into your external MyAPIObject. That causes the raw JSON to be stored, but not unpacked. The next step is to copy (using pkg/conversion) into the internal struct. The runtime package's DefaultScheme has conversion functions installed...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 136.6K bytes
    - Viewed (0)
Back to top