- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for Unmarshal (0.19 sec)
-
common-protos/k8s.io/apimachinery/pkg/runtime/generated.proto
// // { // "kind":"MyAPIObject", // "apiVersion":"v1", // "myPlugin": { // "kind":"PluginA", // "aOption":"foo", // }, // } // // So 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
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/version/version.go
Info: istioVersion.BuildInfo{ Version: "MISSING CP ID", }, Revision: "MISSING CP ID", }, }, nil } cpID := xds.IstioControlPlaneInstance{} err = json.Unmarshal([]byte(xdsResponse.ControlPlane.Identifier), &cpID) if err != nil { return nil, fmt.Errorf("could not parse CP Identifier: %w", err) } return &istioVersion.MeshInfo{ istioVersion.ServerInfo{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
return } } func processAddEvent(body []byte) (CNIPluginAddEvent, error) { var msg CNIPluginAddEvent err := json.Unmarshal(body, &msg) if err != nil { log.Errorf("Failed to unmarshal CNI plugin event: %v", err) return msg, err } log.Debugf("Deserialized CNI plugin event: %+v", msg) return msg, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
func ReadCNIConfigMap(path string) (map[string]any, error) { cniConfig, err := os.ReadFile(path) if err != nil { return nil, err } var cniConfigMap map[string]any if err = json.Unmarshal(cniConfig, &cniConfigMap); err != nil { return nil, fmt.Errorf("%s: %w", path, err) } return cniConfigMap, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/util/proto/messageslice.go
// limitations under the License. package proto import ( "bytes" "google.golang.org/protobuf/proto" "istio.io/istio/pkg/util/protomarshal" ) // MessageSlice allows us to marshal slices of protobuf messages like clusters/listeners/routes/endpoints correctly type MessageSlice []proto.Message // MarshalJSON handles marshaling of slices of proto messages
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 19 21:53:59 GMT 2021 - 1.3K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
defer req.Body.Close() data, err := io.ReadAll(req.Body) assert.NoError(t, err) var msg nodeagent.CNIPluginAddEvent err = json.Unmarshal(data, &msg) assert.NoError(t, err) assert.Equal(t, msg.PodName, testPod) assert.Equal(t, msg.PodNamespace, testNS) assert.Equal(t, msg.Netns, fakeCmdArgs.Netns) res.WriteHeader(http.StatusOK)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
if r := cmp.Compare(a.Name, b.Name); r != 0 { return r } return cmp.Compare(a.Hostname, b.Hostname) }) out, err := json.MarshalIndent(svcs, "", " ") if err != nil { return fmt.Errorf("failed to marshal workloads: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/configdump.go
} bootstrapDump, err := c.configDump.GetBootstrapConfigDump() if err != nil { return err } out, err := protomarshal.ToJSONWithIndent(bootstrapDump, " ") if err != nil { return fmt.Errorf("unable to marshal bootstrap in Envoy config dump: %v", err) } if outputFormat == "yaml" { outbyte, err := yaml.JSONToYAML([]byte(out)) if err != nil { return err } out = string(outbyte) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 29 20:46:41 GMT 2024 - 7.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
Ack: &zdsapi.Ack{}, }, } data, err := proto.Marshal(ack) if err != nil { panic(err) } err = c.SetWriteDeadline(time.Now().Add(time.Second)) if err != nil { panic(err) } c.Write(data) } func sendHello(c *net.UnixConn) { ack := &zdsapi.ZdsHello{ Version: zdsapi.Version_V1, } data, err := proto.Marshal(ack) if err != nil { panic(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
if filter.Namespace != "" && filter.Namespace != state.Info.Namespace { return false } return true }) out, err := json.MarshalIndent(workloads, "", " ") if err != nil { return fmt.Errorf("failed to marshal workloads: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0)