Versions in this module Expand all Collapse all v1 v1.70.0 Feb 9, 2025 Changes in this version + const SocketTypeListen + const SocketTypeNormal + func AddTraceEvent(l grpclog.DepthLoggerV2, e Entity, depth int, desc *TraceEvent) + func Error(l grpclog.DepthLoggerV2, e Entity, args ...any) + func Errorf(l grpclog.DepthLoggerV2, e Entity, format string, args ...any) + func Info(l grpclog.DepthLoggerV2, e Entity, args ...any) + func Infof(l grpclog.DepthLoggerV2, e Entity, format string, args ...any) + func ResetMaxTraceEntryToDefault() + func SetMaxTraceEntry(i int32) + func Warning(l grpclog.DepthLoggerV2, e Entity, args ...any) + func Warningf(l grpclog.DepthLoggerV2, e Entity, format string, args ...any) type Channel + ChannelMetrics ChannelMetrics + ID int64 + Parent *Channel + RefName string + func (c *Channel) NestedChans() map[int64]string + func (c *Channel) String() string + func (c *Channel) SubChans() map[int64]string + func (c *Channel) Trace() *ChannelTrace + type ChannelMetrics struct + CallsFailed atomic.Int64 + CallsStarted atomic.Int64 + CallsSucceeded atomic.Int64 + LastCallStartedTimestamp atomic.Int64 + State atomic.Pointer[connectivity.State] + Target atomic.Pointer[string] + func NewChannelMetricForTesting(state connectivity.State, target string, ...) *ChannelMetrics + func (c *ChannelMetrics) CopyFrom(o *ChannelMetrics) + func (c *ChannelMetrics) Equal(o any) bool + func (c *ChannelMetrics) String() string + type ChannelTrace struct + CreationTime time.Time + EventNum int64 + Events []*traceEvent + type Entity interface + type EphemeralSocketMetrics struct + LocalFlowControlWindow int64 + RemoteFlowControlWindow int64 + type IDGenerator struct + var EntriesPerPage = 50 + var IDGen IDGenerator + func (i *IDGenerator) Reset() + type Identifier interface + type RefChannelType int + const RefChannel + const RefListenSocket + const RefNormalSocket + const RefServer + const RefSubChannel + const RefUnknown + func (r RefChannelType) String() string type Server + ID int64 + RefName string + ServerMetrics ServerMetrics + func GetServer(id int64) *Server + func (s *Server) ListenSockets() map[int64]string + func (s *Server) String() string + type ServerMetrics struct + CallsFailed atomic.Int64 + CallsStarted atomic.Int64 + CallsSucceeded atomic.Int64 + LastCallStartedTimestamp atomic.Int64 + func NewServerMetricsForTesting(started, succeeded, failed, timestamp int64) *ServerMetrics + func (sm *ServerMetrics) CopyFrom(o *ServerMetrics) + type Severity int + const CtError + const CtInfo + const CtUnknown + const CtWarning type Socket + EphemeralMetrics func() *EphemeralSocketMetrics + ID int64 + LocalAddr net.Addr + Parent Entity + RefName string + RemoteAddr net.Addr + RemoteName string + Security credentials.ChannelzSecurityValue + SocketMetrics SocketMetrics + SocketOptions *SocketOptionData + SocketType SocketType + func RegisterSocket(skt *Socket) *Socket + func (ls *Socket) String() string + type SocketMetrics struct + KeepAlivesSent atomic.Int64 + LastLocalStreamCreatedTimestamp atomic.Int64 + LastMessageReceivedTimestamp atomic.Int64 + LastMessageSentTimestamp atomic.Int64 + LastRemoteStreamCreatedTimestamp atomic.Int64 + MessagesReceived atomic.Int64 + MessagesSent atomic.Int64 + StreamsFailed atomic.Int64 + StreamsStarted atomic.Int64 + StreamsSucceeded atomic.Int64 + type SocketType string + type SubChannel struct + ChannelMetrics ChannelMetrics + ID int64 + RefName string + func (sc *SubChannel) Sockets() map[int64]string + func (sc *SubChannel) String() string + func (sc *SubChannel) Trace() *ChannelTrace + type TraceEvent struct + Desc string + Parent *TraceEvent + Severity Severity v1.70.0-fix Feb 9, 2025 v1.14.0 Jul 31, 2018 Changes in this version type SocketInternalMetric + Security credentials.ChannelzSecurityValue + SocketOptions *SocketOptionData + type SocketOptionData struct — darwin/amd64, js/wasm, windows/amd64 + func GetSocketOption(c interface{}) *SocketOptionData + type SocketOptionData struct — linux/amd64 + Linger *unix.Linger + RecvTimeout *unix.Timeval + SendTimeout *unix.Timeval + TCPInfo *unix.TCPInfo + func GetSocketOption(socket interface{}) *SocketOptionData + func (s *SocketOptionData) Getsockopt(fd uintptr) v1.13.0 Jun 19, 2018 Changes in this version + var EntryPerPage = 50 + func IsOn() bool + func NewChannelzStorage() + func RegisterChannel(c Channel, pid int64, ref string) int64 + func RegisterListenSocket(s Socket, pid int64, ref string) int64 + func RegisterNormalSocket(s Socket, pid int64, ref string) int64 + func RegisterServer(s Server, ref string) int64 + func RegisterSubChannel(c Channel, pid int64, ref string) int64 + func RemoveEntry(id int64) + func TurnOn() + type Channel interface + ChannelzMetric func() *ChannelInternalMetric + type ChannelInternalMetric struct + CallsFailed int64 + CallsStarted int64 + CallsSucceeded int64 + LastCallStartedTimestamp time.Time + State connectivity.State + Target string + type ChannelMetric struct + ChannelData *ChannelInternalMetric + ID int64 + NestedChans map[int64]string + RefName string + Sockets map[int64]string + SubChans map[int64]string + func GetChannel(id int64) *ChannelMetric + func GetTopChannels(id int64) ([]*ChannelMetric, bool) + type Server interface + ChannelzMetric func() *ServerInternalMetric + type ServerInternalMetric struct + CallsFailed int64 + CallsStarted int64 + CallsSucceeded int64 + LastCallStartedTimestamp time.Time + type ServerMetric struct + ID int64 + ListenSockets map[int64]string + RefName string + ServerData *ServerInternalMetric + func GetServers(id int64) ([]*ServerMetric, bool) + type Socket interface + ChannelzMetric func() *SocketInternalMetric + type SocketInternalMetric struct + KeepAlivesSent int64 + LastLocalStreamCreatedTimestamp time.Time + LastMessageReceivedTimestamp time.Time + LastMessageSentTimestamp time.Time + LastRemoteStreamCreatedTimestamp time.Time + LocalAddr net.Addr + LocalFlowControlWindow int64 + MessagesReceived int64 + MessagesSent int64 + RemoteAddr net.Addr + RemoteFlowControlWindow int64 + RemoteName string + StreamsFailed int64 + StreamsStarted int64 + StreamsSucceeded int64 + type SocketMetric struct + ID int64 + RefName string + SocketData *SocketInternalMetric + func GetServerSockets(id int64, startID int64) ([]*SocketMetric, bool) + func GetSocket(id int64) *SocketMetric + type SubChannelMetric struct + ChannelData *ChannelInternalMetric + ID int64 + NestedChans map[int64]string + RefName string + Sockets map[int64]string + SubChans map[int64]string + func GetSubChannel(id int64) *SubChannelMetric
Go to main page