Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 177 for unmarshaler (0.77 sec)

  1. pkg/config/model.go

    	}
    	pbs := &structpb.Struct{}
    	if err := protomarshal.Unmarshal(js, pbs); err != nil {
    		return nil, err
    	}
    	return protoconv.MessageToAnyWithError(pbs)
    }
    
    func ToMap(s Spec) (map[string]any, error) {
    	js, err := ToJSON(s)
    	if err != nil {
    		return nil, err
    	}
    
    	// Unmarshal from json bytes to go map
    	var data map[string]any
    	err = json.Unmarshal(js, &data)
    	if err != nil {
    		return nil, err
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. src/cmd/go/internal/modinfo/info.go

    // UnmarshalJSON accepts both {"Err":"text"} and "text",
    // so that the output of go mod download -json can still
    // be unmarshaled into a ModulePublic during -reuse processing.
    func (e *ModuleError) UnmarshalJSON(data []byte) error {
    	if len(data) > 0 && data[0] == '"' {
    		return json.Unmarshal(data, &e.Err)
    	}
    	return json.Unmarshal(data, (*moduleErrorNoMethods)(e))
    }
    
    func (m *ModulePublic) String() string {
    	s := m.Path
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. pilot/pkg/xds/ecds_test.go

    			gotSecrets := sets.String{}
    			for _, res := range resources {
    				gotExtensions.Insert(res.Name)
    				ec := &core.TypedExtensionConfig{}
    				res.Resource.UnmarshalTo(ec)
    				wasm := &wasm.Wasm{}
    				ec.TypedConfig.UnmarshalTo(wasm)
    				gotsecret := wasm.GetConfig().GetVmConfig().GetEnvironmentVariables().GetKeyValues()[model.WasmSecretEnv]
    				if gotsecret != "" {
    					gotSecrets.Insert(gotsecret)
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 12K 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. 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)
  7. pilot/pkg/model/telemetry_test.go

    						w := &stats.PluginConfig{}
    						if err := f.GetTypedConfig().UnmarshalTo(w); err != nil {
    							t.Fatal(err)
    						}
    						cfgJSON, _ := protomarshal.MarshalProtoNames(w)
    						res[f.GetName()] = string(cfgJSON)
    					} else {
    						w := &httpwasm.Wasm{}
    
    						if err := f.GetTypedConfig().UnmarshalTo(w); err != nil {
    							t.Fatal(err)
    						}
    						cfg := &wrappers.StringValue{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  8. pkg/kube/apimirror/probe.go

    	Type   Type
    	IntVal int32
    	StrVal string
    }
    
    // UnmarshalJSON implements the json.Unmarshaller interface.
    func (intstr *IntOrString) UnmarshalJSON(value []byte) error {
    	if value[0] == '"' {
    		intstr.Type = String
    		return json.Unmarshal(value, &intstr.StrVal)
    	}
    	intstr.Type = Int
    	return json.Unmarshal(value, &intstr.IntVal)
    }
    
    // MarshalJSON implements the json.Marshaller interface.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. istioctl/pkg/version/version.go

    			switch resource.TypeUrl {
    			case "type.googleapis.com/envoy.config.core.v3.Node":
    				node := core.Node{}
    				err := resource.UnmarshalTo(&node)
    				if err != nil {
    					return nil, fmt.Errorf("could not unmarshal Node: %w", err)
    				}
    				meta, err := model.ParseMetadata(node.Metadata)
    				if err != nil || meta.ProxyConfig == nil {
    					// Skip non-sidecars (e.g. istioctl queries)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 15 01:18:49 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. 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)
Back to top