Class InternalChannelz

java.lang.Object

io.grpc.InternalChannelz

@Internal
public final class InternalChannelz
extends Object

This is an internal API. Do NOT use.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	InternalChannelz.ChannelStats	A data class to represent a channel's stats.
static final class	InternalChannelz.ChannelTrace
static final class	InternalChannelz.OtherSecurity
static final class	InternalChannelz.RootChannelList
static final class	InternalChannelz.Security
static final class	InternalChannelz.ServerList
private static final class	InternalChannelz.ServerSocketMap
static final class	InternalChannelz.ServerSocketsList
static final class	InternalChannelz.ServerStats
static final class	InternalChannelz.SocketOptions
static final class	InternalChannelz.SocketStats
static final class	InternalChannelz.TcpInfo
static final class	InternalChannelz.Tls
static final class	InternalChannelz.TransportStats	A data class to represent transport stats.

Field Summary

Fields

Modifier and Type	Field	Description
private static final InternalChannelz	INSTANCE
private static final Logger	log
private final ConcurrentMap<Long, InternalInstrumented<InternalChannelz.SocketStats>>	otherSockets
private final ConcurrentMap<Long, InternalChannelz.ServerSocketMap>	perServerSockets
private final ConcurrentNavigableMap<Long, InternalInstrumented<InternalChannelz.ChannelStats>>	rootChannels
private final ConcurrentNavigableMap<Long, InternalInstrumented<InternalChannelz.ServerStats>>	servers
private final ConcurrentMap<Long, InternalInstrumented<InternalChannelz.ChannelStats>>	subchannels

Constructor Summary

Constructors

Constructor	Description
InternalChannelz()

Method Summary

Modifier and Type	Method	Description
private static <T extends InternalInstrumented<?>> void	add(Map<Long,T> map, T object)
void	addClientSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)	Adds a socket.
void	addListenSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)
void	addRootChannel(InternalInstrumented<InternalChannelz.ChannelStats> rootChannel)	Adds a root channel.
void	addServer(InternalInstrumented<InternalChannelz.ServerStats> server)	Adds a server.
void	addServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket)	Adds a server socket.
void	addSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)	Adds a subchannel.
private static <T extends InternalInstrumented<?>> boolean	contains(Map<Long,T> map, InternalLogId id)
boolean	containsClientSocket(InternalLogId transportRef)
boolean	containsServer(InternalLogId serverRef)
boolean	containsSubchannel(InternalLogId subchannelRef)
InternalInstrumented<InternalChannelz.ChannelStats>	getChannel(long id)	Returns a channel.
InternalInstrumented<InternalChannelz.ChannelStats>	getRootChannel(long id)
InternalChannelz.RootChannelList	getRootChannels(long fromId, int maxPageSize)	Returns a InternalChannelz.RootChannelList.
InternalInstrumented<InternalChannelz.ServerStats>	getServer(long id)	Returns a server.
InternalChannelz.ServerList	getServers(long fromId, int maxPageSize)	Returns a server list.
private InternalInstrumented<InternalChannelz.SocketStats>	getServerSocket(long id)
InternalChannelz.ServerSocketsList	getServerSockets(long serverId, long fromId, int maxPageSize)	Returns socket refs for a server.
InternalInstrumented<InternalChannelz.SocketStats>	getSocket(long id)	Returns a socket.
InternalInstrumented<InternalChannelz.ChannelStats>	getSubchannel(long id)	Returns a subchannel.
static long	id(InternalWithLogId withLogId)	Unwraps a InternalLogId to return a long.
static InternalChannelz	instance()
private static <T extends InternalInstrumented<?>> void	remove(Map<Long,T> map, T object)
void	removeClientSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)
void	removeListenSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)
void	removeRootChannel(InternalInstrumented<InternalChannelz.ChannelStats> channel)
void	removeServer(InternalInstrumented<InternalChannelz.ServerStats> server)	Removes a server.
void	removeServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket)	Removes a server socket.
void	removeSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

private static final Logger log

INSTANCE

private static final InternalChannelz INSTANCE

servers

private final ConcurrentNavigableMap<Long, InternalInstrumented<InternalChannelz.ServerStats>> servers

rootChannels

private final ConcurrentNavigableMap<Long, InternalInstrumented<InternalChannelz.ChannelStats>> rootChannels

subchannels

private final ConcurrentMap<Long, InternalInstrumented<InternalChannelz.ChannelStats>> subchannels

otherSockets

private final ConcurrentMap<Long, InternalInstrumented<InternalChannelz.SocketStats>> otherSockets

perServerSockets

private final ConcurrentMap<Long, InternalChannelz.ServerSocketMap> perServerSockets

Constructor Details

InternalChannelz

public InternalChannelz()

Method Details

instance

public static InternalChannelz instance()

addServer

public void addServer(InternalInstrumented<InternalChannelz.ServerStats> server)

Adds a server.

addSubchannel

public void addSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)

Adds a subchannel.

addRootChannel

public void addRootChannel(InternalInstrumented<InternalChannelz.ChannelStats> rootChannel)

Adds a root channel.

addClientSocket

public void addClientSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)

Adds a socket.

addListenSocket

public void addListenSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)

addServerSocket

public void addServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server,
 InternalInstrumented<InternalChannelz.SocketStats> socket)

Adds a server socket.

removeServer

public void removeServer(InternalInstrumented<InternalChannelz.ServerStats> server)

Removes a server.

removeSubchannel

public void removeSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)

removeRootChannel

public void removeRootChannel(InternalInstrumented<InternalChannelz.ChannelStats> channel)

removeClientSocket

public void removeClientSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)

removeListenSocket

public void removeListenSocket(InternalInstrumented<InternalChannelz.SocketStats> socket)

removeServerSocket

public void removeServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server,
 InternalInstrumented<InternalChannelz.SocketStats> socket)

Removes a server socket.

getRootChannels

public InternalChannelz.RootChannelList getRootChannels(long fromId,
 int maxPageSize)

Returns a InternalChannelz.RootChannelList.

getChannel

@Nullable
public InternalInstrumented<InternalChannelz.ChannelStats> getChannel(long id)

Returns a channel.

getSubchannel

@Nullable
public InternalInstrumented<InternalChannelz.ChannelStats> getSubchannel(long id)

Returns a subchannel.

getServers

public InternalChannelz.ServerList getServers(long fromId,
 int maxPageSize)

Returns a server list.

getServer

@Nullable
public InternalInstrumented<InternalChannelz.ServerStats> getServer(long id)

Returns a server.

getServerSockets

@Nullable
public InternalChannelz.ServerSocketsList getServerSockets(long serverId,
 long fromId,
 int maxPageSize)

Returns socket refs for a server.

getSocket

@Nullable
public InternalInstrumented<InternalChannelz.SocketStats> getSocket(long id)

Returns a socket.

getServerSocket

private InternalInstrumented<InternalChannelz.SocketStats> getServerSocket(long id)

containsServer

public boolean containsServer(InternalLogId serverRef)

containsSubchannel

public boolean containsSubchannel(InternalLogId subchannelRef)

getRootChannel

public InternalInstrumented<InternalChannelz.ChannelStats> getRootChannel(long id)

containsClientSocket

public boolean containsClientSocket(InternalLogId transportRef)

add

private static <T extends InternalInstrumented<?>>
void add(Map<Long,T> map,
 T object)

remove

private static <T extends InternalInstrumented<?>>
void remove(Map<Long,T> map,
 T object)

contains

private static <T extends InternalInstrumented<?>>
boolean contains(Map<Long,T> map,
 InternalLogId id)

id

public static long id(InternalWithLogId withLogId)

Unwraps a InternalLogId to return a long.