- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for qmsg (0.13 sec)
-
istioctl/pkg/tag/tag.go
res, err := sa.Analyze(make(chan struct{})) if err != nil { return err } relevantMessages := diag.Messages{} for _, msg := range res.Messages.FilterOutLowerThan(diag.Error) { if msg.Resource.Metadata.FullName.Name == resource.LocalName(name) { relevantMessages = append(relevantMessages, msg) } } if len(relevantMessages) > 0 { o, err := formatting.Print(relevantMessages, formatting.LogFormat, false)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.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) -
cni/pkg/nodeagent/ztunnelserver.go
select { case r := <-ret: return r.resp, r.err case <-ctx.Done(): return nil, ctx.Err() } } func (z *ZtunnelConnection) sendMsgAndWaitForAck(msg *zdsapi.WorkloadRequest, fd *int) (*zdsapi.WorkloadResponse, error) { data, err := proto.Marshal(msg) if err != nil { return nil, err } return z.sendDataAndWaitForAck(data, fd) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
defer func() { if e := recover(); e != nil { msg := fmt.Sprintf("istio-cni panicked during cmdAdd: %v\n%v", e, string(debug.Stack())) if err != nil { // If we're recovering and there was also an error, then we need to // present both. msg = fmt.Sprintf("%s: %v", msg, err) } err = fmt.Errorf(msg) } if err != nil { log.Errorf("istio-cni cmdAdd error: %v", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K 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) -
istioctl/pkg/analyze/analyze.go
"istio.io/istio/pkg/config/analysis" "istio.io/istio/pkg/config/analysis/analyzers" "istio.io/istio/pkg/config/analysis/diag" "istio.io/istio/pkg/config/analysis/local" "istio.io/istio/pkg/config/analysis/msg" "istio.io/istio/pkg/config/resource" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/multicluster" "istio.io/istio/pkg/log" "istio.io/istio/pkg/url" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K 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)