- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for qmsg (0.18 sec)
-
istioctl/pkg/util/proto/messageslice.go
// MarshalJSON handles marshaling of slices of proto messages func (pSlice MessageSlice) MarshalJSON() ([]byte, error) { buffer := bytes.NewBufferString("[") sliceLength := len(pSlice) for index, msg := range pSlice { b, err := protomarshal.Marshal(msg) if err != nil { return nil, err } buffer.Write(b) if index < sliceLength-1 { buffer.WriteString(",") } } buffer.WriteString("]") return buffer.Bytes(), nil
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) -
istioctl/pkg/util/configdump/wrapper.go
typ, err := r.Types.FindMessageByURL(url) if err != nil { // Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}} return msg.ProtoReflect().Type(), nil } return typ, nil } // Wrapper is a wrapper around the Envoy ConfigDump // It has extra helper functions for handling any/struct/marshal protobuf pain
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
if err != nil { panic(err) } // we should get 0 or 1 oob messages if len(msgs) != 0 { assert.Equal(t, len(msgs), 1) } var fdss []int for _, msg := range msgs { fds, err := unix.ParseUnixRights(&msg) if err != nil { panic(err) } fdss = append(fdss, fds...) } return m, fdss } func sendAck(c *net.UnixConn) { ack := &zdsapi.WorkloadResponse{
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) -
cni/pkg/log/uds.go
return } messages := make([]cniLog, 0, len(cniLogs)) for _, l := range cniLogs { var msg cniLog if err := json.Unmarshal([]byte(l), &msg); err != nil { log.Debugf("Failed to unmarshal CNI plugin log entry: %v", err) continue } msg.Msg = strings.TrimSpace(msg.Msg) messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false } switch strings.ToUpper(response) { case "Y", "YES": return true
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
istioctl/pkg/util/formatting/msg_threshold.go
Mitch Connors <******@****.***> 1637152085 -0800
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 17 12:28:05 GMT 2021 - 1.4K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
func kubeBuilderInstalled() bool { ev := os.Getenv("KUBEBUILDER") return ev == "true" || ev == "1" } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false } switch strings.ToUpper(response) { case "Y", "YES": return true
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K 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/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) res.Write([]byte("server happy")) }))
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)