Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 188 for unmarshaler (0.22 sec)

  1. pilot/pkg/xds/nds_test.go

    				Node: &core.Node{
    					Id:       ads.ID,
    					Metadata: tt.meta.ToStruct(),
    				},
    			})
    
    			nt := &dnsProto.NameTable{}
    			err := res.Resources[0].UnmarshalTo(nt)
    			if err != nil {
    				t.Fatal("Failed to unmarshal name table", err)
    				return
    			}
    			if len(nt.Table) == 0 {
    				t.Fatalf("expected more than 0 entries in name table")
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. pkg/istio-agent/xds_proxy.go

    	}
    
    	if ia.localDNSServer != nil {
    		proxy.handlers[model.NameTableType] = func(resp *anypb.Any) error {
    			var nt dnsProto.NameTable
    			if err := resp.UnmarshalTo(&nt); err != nil {
    				log.Errorf("failed to unmarshal name table: %v", err)
    				return err
    			}
    			ia.localDNSServer.UpdateLookupTable(&nt)
    			return nil
    		}
    	}
    	if ia.cfg.EnableDynamicProxyConfig && ia.secretCache != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time.go

    	return MicroTime{time.Unix(sec, nsec)}
    }
    
    // UnmarshalJSON implements the json.Unmarshaller interface.
    func (t *MicroTime) UnmarshalJSON(b []byte) error {
    	if len(b) == 4 && string(b) == "null" {
    		t.Time = time.Time{}
    		return nil
    	}
    
    	var str string
    	err := json.Unmarshal(b, &str)
    	if err != nil {
    		return err
    	}
    
    	pt, err := time.Parse(RFC3339Micro, str)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/rbac/v1beta1/generated.pb.go

    func (*AggregationRule) ProtoMessage() {}
    func (*AggregationRule) Descriptor() ([]byte, []int) {
    	return fileDescriptor_c5bc2d145acd4e45, []int{0}
    }
    func (m *AggregationRule) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *AggregationRule) 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
    - 77.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/rbac/v1alpha1/generated.pb.go

    func (*AggregationRule) ProtoMessage() {}
    func (*AggregationRule) Descriptor() ([]byte, []int) {
    	return fileDescriptor_758889dfd9a88fa6, []int{0}
    }
    func (m *AggregationRule) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *AggregationRule) 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
    - 77.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/storage/v1alpha1/generated.pb.go

    func (*CSIStorageCapacity) ProtoMessage() {}
    func (*CSIStorageCapacity) Descriptor() ([]byte, []int) {
    	return fileDescriptor_02e7952e43280c27, []int{0}
    }
    func (m *CSIStorageCapacity) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *CSIStorageCapacity) 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
    - 76.5K bytes
    - Viewed (0)
  7. 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)
  8. staging/src/k8s.io/api/policy/v1beta1/generated.pb.go

    func (*Eviction) ProtoMessage() {}
    func (*Eviction) Descriptor() ([]byte, []int) {
    	return fileDescriptor_68b366237812cc96, []int{0}
    }
    func (m *Eviction) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *Eviction) 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
    - 45.2K bytes
    - Viewed (0)
  9. internal/s3select/select.go

    	JSONArgs        json.ReaderArgs    `xml:"JSON"`
    	ParquetArgs     parquet.ReaderArgs `xml:"Parquet"`
    	unmarshaled     bool
    	format          string
    }
    
    // IsEmpty - returns whether input serialization is empty or not.
    func (input *InputSerialization) IsEmpty() bool {
    	return !input.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 21K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/events/v1/generated.pb.go

    func (*Event) ProtoMessage() {}
    func (*Event) Descriptor() ([]byte, []int) {
    	return fileDescriptor_d3a3e1495c224e47, []int{0}
    }
    func (m *Event) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *Event) 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
    - 35.6K bytes
    - Viewed (0)
Back to top