Versions in this module Expand all Collapse all v1 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