channelz

Documentation

Overview

Package channelz defines APIs for enabling channelz service, entry registration/deletion, and accessing channelz data. It also defines channelz metric struct formats.

All APIs in this package are experimental.

Index

• Variables
• 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
• type ChannelInternalMetric
• type ChannelMetric
  • func GetChannel(id int64) *ChannelMetric
  • func GetTopChannels(id int64) ([]*ChannelMetric, bool)
• type Server
• type ServerInternalMetric
• type ServerMetric
  • func GetServers(id int64) ([]*ServerMetric, bool)
• type Socket
• type SocketInternalMetric
• type SocketMetric
  • func GetServerSockets(id int64, startID int64) ([]*SocketMetric, bool)
  • func GetSocket(id int64) *SocketMetric
• type SocketOptionData
  • func GetSocketOption(socket interface{}) *SocketOptionData
  • func (s *SocketOptionData) Getsockopt(fd uintptr)
• type SubChannelMetric
  • func GetSubChannel(id int64) *SubChannelMetric

Variables

var (

	// EntryPerPage defines the number of channelz entries to be shown on a web page.
	EntryPerPage = 50
)

Functions

func IsOn

func IsOn() bool

IsOn returns whether channelz data collection is on.

func NewChannelzStorage

func NewChannelzStorage()

NewChannelzStorage initializes channelz data storage and id generator.

Note: This function is exported for testing purpose only. User should not call it in most cases.

func RegisterChannel

func RegisterChannel(c Channel, pid int64, ref string) int64

RegisterChannel registers the given channel c in channelz database with ref as its reference name, and add it to the child list of its parent (identified by pid). pid = 0 means no parent. It returns the unique channelz tracking id assigned to this channel.

func RegisterListenSocket

func RegisterListenSocket(s Socket, pid int64, ref string) int64

RegisterListenSocket registers the given listen socket s in channelz database with ref as its reference name, and add it to the child list of its parent (identified by pid). It returns the unique channelz tracking id assigned to this listen socket.

func RegisterNormalSocket

func RegisterNormalSocket(s Socket, pid int64, ref string) int64

RegisterNormalSocket registers the given normal socket s in channelz database with ref as its reference name, and add it to the child list of its parent (identified by pid). It returns the unique channelz tracking id assigned to this normal socket.

func RegisterServer

func RegisterServer(s Server, ref string) int64

RegisterServer registers the given server s in channelz database. It returns the unique channelz tracking id assigned to this server.

func RegisterSubChannel

func RegisterSubChannel(c Channel, pid int64, ref string) int64

RegisterSubChannel registers the given channel c in channelz database with ref as its reference name, and add it to the child list of its parent (identified by pid). It returns the unique channelz tracking id assigned to this subchannel.

func RemoveEntry

func RemoveEntry(id int64)

RemoveEntry removes an entry with unique channelz trakcing id to be id from channelz database.

func TurnOn

func TurnOn()

TurnOn turns on channelz data collection.

Types

type Channel

type Channel interface {
	ChannelzMetric() *ChannelInternalMetric
}

Channel is the interface that should be satisfied in order to be tracked by channelz as Channel or SubChannel.

type ChannelInternalMetric

type ChannelInternalMetric struct {
	// current connectivity state of the channel.
	State connectivity.State
	// The target this channel originally tried to connect to.  May be absent
	Target string
	// The number of calls started on the channel.
	CallsStarted int64
	// The number of calls that have completed with an OK status.
	CallsSucceeded int64
	// The number of calls that have a completed with a non-OK status.
	CallsFailed int64
	// The last time a call was started on the channel.
	LastCallStartedTimestamp time.Time
}

ChannelInternalMetric defines the struct that the implementor of Channel interface should return from ChannelzMetric().

type ChannelMetric

type ChannelMetric struct {
	// ID is the channelz id of this channel.
	ID int64
	// RefName is the human readable reference string of this channel.
	RefName string
	// ChannelData contains channel internal metric reported by the channel through
	// ChannelzMetric().
	ChannelData *ChannelInternalMetric
	// NestedChans tracks the nested channel type children of this channel in the format of
	// a map from nested channel channelz id to corresponding reference string.
	NestedChans map[int64]string
	// SubChans tracks the subchannel type children of this channel in the format of a
	// map from subchannel channelz id to corresponding reference string.
	SubChans map[int64]string
	// Sockets tracks the socket type children of this channel in the format of a map
	// from socket channelz id to corresponding reference string.
	// Note current grpc implementation doesn't allow channel having sockets directly,
	// therefore, this is field is unused.
	Sockets map[int64]string
}

ChannelMetric defines the info channelz provides for a specific Channel, which includes ChannelInternalMetric and channelz-specific data, such as channelz id, child list, etc.

func GetChannel

func GetChannel(id int64) *ChannelMetric

GetChannel returns the ChannelMetric for the channel (identified by id).

func GetTopChannels

func GetTopChannels(id int64) ([]*ChannelMetric, bool)

GetTopChannels returns a slice of top channel's ChannelMetric, along with a boolean indicating whether there's more top channels to be queried for.

The arg id specifies that only top channel with id at or above it will be included in the result. The returned slice is up to a length of EntryPerPage, and is sorted in ascending id order.

type Server

type Server interface {
	ChannelzMetric() *ServerInternalMetric
}

Server is the interface to be satisfied in order to be tracked by channelz as Server.

type ServerInternalMetric

type ServerInternalMetric struct {
	// The number of incoming calls started on the server.
	CallsStarted int64
	// The number of incoming calls that have completed with an OK status.
	CallsSucceeded int64
	// The number of incoming calls that have a completed with a non-OK status.
	CallsFailed int64
	// The last time a call was started on the server.
	LastCallStartedTimestamp time.Time
}

ServerInternalMetric defines the struct that the implementor of Server interface should return from ChannelzMetric().

type ServerMetric

type ServerMetric struct {
	// ID is the channelz id of this server.
	ID int64
	// RefName is the human readable reference string of this server.
	RefName string
	// ServerData contains server internal metric reported by the server through
	// ChannelzMetric().
	ServerData *ServerInternalMetric
	// ListenSockets tracks the listener socket type children of this server in the
	// format of a map from socket channelz id to corresponding reference string.
	ListenSockets map[int64]string
}

ServerMetric defines the info channelz provides for a specific Server, which includes ServerInternalMetric and channelz-specific data, such as channelz id, child list, etc.

func GetServers

func GetServers(id int64) ([]*ServerMetric, bool)

GetServers returns a slice of server's ServerMetric, along with a boolean indicating whether there's more servers to be queried for.

The arg id specifies that only server with id at or above it will be included in the result. The returned slice is up to a length of EntryPerPage, and is sorted in ascending id order.

type Socket

type Socket interface {
	ChannelzMetric() *SocketInternalMetric
}

Socket is the interface that should be satisfied in order to be tracked by channelz as Socket.

type SocketInternalMetric

type SocketInternalMetric struct {
	// The number of streams that have been started.
	StreamsStarted int64
	// The number of streams that have ended successfully:
	// On client side, receiving frame with eos bit set.
	// On server side, sending frame with eos bit set.
	StreamsSucceeded int64
	// The number of streams that have ended unsuccessfully:
	// On client side, termination without receiving frame with eos bit set.
	// On server side, termination without sending frame with eos bit set.
	StreamsFailed int64
	// The number of messages successfully sent on this socket.
	MessagesSent     int64
	MessagesReceived int64
	// The number of keep alives sent.  This is typically implemented with HTTP/2
	// ping messages.
	KeepAlivesSent int64
	// The last time a stream was created by this endpoint.  Usually unset for
	// servers.
	LastLocalStreamCreatedTimestamp time.Time
	// The last time a stream was created by the remote endpoint.  Usually unset
	// for clients.
	LastRemoteStreamCreatedTimestamp time.Time
	// The last time a message was sent by this endpoint.
	LastMessageSentTimestamp time.Time
	// The last time a message was received by this endpoint.
	LastMessageReceivedTimestamp time.Time
	// The amount of window, granted to the local endpoint by the remote endpoint.
	// This may be slightly out of date due to network latency.  This does NOT
	// include stream level or TCP level flow control info.
	LocalFlowControlWindow int64
	// The amount of window, granted to the remote endpoint by the local endpoint.
	// This may be slightly out of date due to network latency.  This does NOT
	// include stream level or TCP level flow control info.
	RemoteFlowControlWindow int64
	// The locally bound address.
	LocalAddr net.Addr
	// The remote bound address.  May be absent.
	RemoteAddr net.Addr
	// Optional, represents the name of the remote endpoint, if different than
	// the original target name.
	RemoteName    string
	SocketOptions *SocketOptionData
	Security      credentials.ChannelzSecurityValue
}

SocketInternalMetric defines the struct that the implementor of Socket interface should return from ChannelzMetric().

type SocketMetric

type SocketMetric struct {
	// ID is the channelz id of this socket.
	ID int64
	// RefName is the human readable reference string of this socket.
	RefName string
	// SocketData contains socket internal metric reported by the socket through
	// ChannelzMetric().
	SocketData *SocketInternalMetric
}

SocketMetric defines the info channelz provides for a specific Socket, which includes SocketInternalMetric and channelz-specific data, such as channelz id, etc.

func GetServerSockets

func GetServerSockets(id int64, startID int64) ([]*SocketMetric, bool)

GetServerSockets returns a slice of server's (identified by id) normal socket's SocketMetric, along with a boolean indicating whether there's more sockets to be queried for.

The arg startID specifies that only sockets with id at or above it will be included in the result. The returned slice is up to a length of EntryPerPage, and is sorted in ascending id order.

func GetSocket

func GetSocket(id int64) *SocketMetric

GetSocket returns the SocketInternalMetric for the socket (identified by id).

type SocketOptionData

type SocketOptionData struct {
	Linger      *unix.Linger
	RecvTimeout *unix.Timeval
	SendTimeout *unix.Timeval
	TCPInfo     *unix.TCPInfo
}

SocketOptionData defines the struct to hold socket option data, and related getter function to obtain info from fd.

func GetSocketOption

func GetSocketOption(socket interface{}) *SocketOptionData

GetSocketOption gets the socket option info of the conn.

func (*SocketOptionData) Getsockopt

func (s *SocketOptionData) Getsockopt(fd uintptr)

Getsockopt defines the function to get socket options requested by channelz. It is to be passed to syscall.RawConn.Control().

type SubChannelMetric

type SubChannelMetric struct {
	// ID is the channelz id of this subchannel.
	ID int64
	// RefName is the human readable reference string of this subchannel.
	RefName string
	// ChannelData contains subchannel internal metric reported by the subchannel
	// through ChannelzMetric().
	ChannelData *ChannelInternalMetric
	// NestedChans tracks the nested channel type children of this subchannel in the format of
	// a map from nested channel channelz id to corresponding reference string.
	// Note current grpc implementation doesn't allow subchannel to have nested channels
	// as children, therefore, this field is unused.
	NestedChans map[int64]string
	// SubChans tracks the subchannel type children of this subchannel in the format of a
	// map from subchannel channelz id to corresponding reference string.
	// Note current grpc implementation doesn't allow subchannel to have subchannels
	// as children, therefore, this field is unused.
	SubChans map[int64]string
	// Sockets tracks the socket type children of this subchannel in the format of a map
	// from socket channelz id to corresponding reference string.
	Sockets map[int64]string
}

SubChannelMetric defines the info channelz provides for a specific SubChannel, which includes ChannelInternalMetric and channelz-specific data, such as channelz id, child list, etc.

func GetSubChannel

func GetSubChannel(id int64) *SubChannelMetric

GetSubChannel returns the SubChannelMetric for the subchannel (identified by id).