Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 345 for unmarshaler (1.64 sec)

  1. internal/s3select/csv/args.go

    	CommentCharacter           string `xml:"Comments"`
    	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
    	unmarshaled                bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  2. pkg/apis/resource/install/install_test.go

    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	other := internal.ResourceClaim{}
    	if err := json.Unmarshal(data, &other); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if other.APIVersion != "resource.k8s.io/v1alpha2" || other.Kind != "ResourceClaim" {
    		t.Errorf("unexpected unmarshalled object %#v", other)
    	}
    }
    
    func TestUnversioned(t *testing.T) {
    	for _, obj := range []runtime.Object{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 06:52:03 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  3. istioctl/pkg/authz/listener.go

    	filterChains []*filterChain
    }
    
    func getFilterConfig(filter *listener.Filter, out proto.Message) error {
    	switch c := filter.ConfigType.(type) {
    	case *listener.Filter_TypedConfig:
    		if err := c.TypedConfig.UnmarshalTo(out); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager {
    	cm := &hcm.HttpConnectionManager{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. src/syscall/dir_plan9.go

    	b = pstring(b, d.Gid)
    	b = pstring(b, d.Muid)
    
    	return n, nil
    }
    
    // UnmarshalDir decodes a single 9P stat message from b and returns the resulting Dir.
    //
    // If b is too small to hold a valid stat message, [ErrShortStat] is returned.
    //
    // If the stat message itself is invalid, [ErrBadStat] is returned.
    func UnmarshalDir(b []byte) (*Dir, error) {
    	if len(b) < STATFIXLEN {
    		return nil, ErrShortStat
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 19:32:38 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. src/os/dir_plan9.go

    		m := int(uint16(b[0])|uint16(b[1])<<8) + 2
    		if m < syscall.STATFIXLEN {
    			return names, dirents, infos, &PathError{Op: "readdir", Path: file.name, Err: syscall.ErrShortStat}
    		}
    
    		dir, err := syscall.UnmarshalDir(b[:m])
    		if err != nil {
    			return names, dirents, infos, &PathError{Op: "readdir", Path: file.name, Err: err}
    		}
    
    		if mode == readdirName {
    			names = append(names, dir.Name)
    		} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 20:52:06 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/ecds.go

    		return nil, err
    	}
    
    	ecds := make([]*core.TypedExtensionConfig, 0, len(dump.EcdsFilters))
    	for _, config := range dump.GetEcdsFilters() {
    		c := &core.TypedExtensionConfig{}
    		err := config.GetEcdsFilter().UnmarshalTo(c)
    		if err != nil {
    			return nil, fmt.Errorf("failed to retrieve TypedExtensionConfig: %v", err)
    		}
    
    		ecds = append(ecds, c)
    	}
    
    	sort.Slice(ecds, func(i, j int) bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Jan 14 02:41:27 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  7. src/encoding/xml/marshal.go

    	kind := val.Kind()
    	typ := val.Type()
    
    	// Check for marshaler.
    	if val.CanInterface() && typ.Implements(marshalerType) {
    		return p.marshalInterface(val.Interface().(Marshaler), defaultStart(typ, finfo, startTemplate))
    	}
    	if val.CanAddr() {
    		pv := val.Addr()
    		if pv.CanInterface() && pv.Type().Implements(marshalerType) {
    			return p.marshalInterface(pv.Interface().(Marshaler), defaultStart(pv.Type(), finfo, startTemplate))
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 08 18:46:41 UTC 2024
    - 31.2K bytes
    - Viewed (0)
  8. pkg/apis/core/install/install_test.go

    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	other := internal.Pod{}
    	if err := json.Unmarshal(data, &other); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if other.APIVersion != "v1" || other.Kind != "Pod" {
    		t.Errorf("unexpected unmarshalled object %#v", other)
    	}
    }
    
    func TestUnversioned(t *testing.T) {
    	for _, obj := range []runtime.Object{
    		&metav1.Status{},
    	} {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 27 06:11:15 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  9. istioctl/pkg/authz/analyzer.go

    		listenerTyped := &listener.Listener{}
    		// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    		l.ActiveState.Listener.TypeUrl = v3.ListenerType
    		err := l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return
    		}
    		listeners = append(listeners, listenerTyped)
    	}
    	Print(writer, listeners)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jul 13 01:59:17 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  10. pilot/pkg/util/protoconv/protoconv.go

    	if err != nil {
    		return nil
    	}
    	return res
    }
    
    func UnmarshalAny[T any](a *anypb.Any) (*T, error) {
    	dst := any(new(T)).(proto.Message)
    	if err := a.UnmarshalTo(dst); err != nil {
    		return nil, fmt.Errorf("failed to unmarshal to %T: %v", dst, err)
    	}
    	return any(dst).(*T), nil
    }
    
    // https://github.com/planetscale/vtprotobuf#available-features
    type vtStrictMarshal interface {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 04:55:40 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top