- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 345 for unmarshaler (1.64 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)