Package io.grpc
Class InternalChannelz
java.lang.Object
io.grpc.InternalChannelz
This is an internal API. Do NOT use.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class
A data class to represent a channel's stats.static final class
static final class
static final class
static final class
static final class
private static final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
A data class to represent transport stats. -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final InternalChannelz
private static final Logger
private final ConcurrentMap
<Long, InternalInstrumented<InternalChannelz.SocketStats>> private final ConcurrentMap
<Long, InternalChannelz.ServerSocketMap> private final ConcurrentNavigableMap
<Long, InternalInstrumented<InternalChannelz.ChannelStats>> private final ConcurrentNavigableMap
<Long, InternalInstrumented<InternalChannelz.ServerStats>> private final ConcurrentMap
<Long, InternalInstrumented<InternalChannelz.ChannelStats>> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static <T extends InternalInstrumented<?>>
voidvoid
Adds a socket.void
void
addRootChannel
(InternalInstrumented<InternalChannelz.ChannelStats> rootChannel) Adds a root channel.void
Adds a server.void
addServerSocket
(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket) Adds a server socket.void
Adds a subchannel.private static <T extends InternalInstrumented<?>>
booleancontains
(Map<Long, T> map, InternalLogId id) boolean
containsClientSocket
(InternalLogId transportRef) boolean
containsServer
(InternalLogId serverRef) boolean
containsSubchannel
(InternalLogId subchannelRef) getChannel
(long id) Returns a channel.getRootChannel
(long id) getRootChannels
(long fromId, int maxPageSize) Returns aInternalChannelz.RootChannelList
.getServer
(long id) Returns a server.getServers
(long fromId, int maxPageSize) Returns a server list.getServerSocket
(long id) getServerSockets
(long serverId, long fromId, int maxPageSize) Returns socket refs for a server.getSocket
(long id) Returns a socket.getSubchannel
(long id) Returns a subchannel.static long
id
(InternalWithLogId withLogId) Unwraps aInternalLogId
to return along
.static InternalChannelz
instance()
private static <T extends InternalInstrumented<?>>
voidvoid
void
void
void
Removes a server.void
removeServerSocket
(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket) Removes a server socket.void
-
Field Details
-
log
-
INSTANCE
-
servers
private final ConcurrentNavigableMap<Long,InternalInstrumented<InternalChannelz.ServerStats>> servers -
rootChannels
private final ConcurrentNavigableMap<Long,InternalInstrumented<InternalChannelz.ChannelStats>> rootChannels -
subchannels
-
otherSockets
-
perServerSockets
-
-
Constructor Details
-
InternalChannelz
public InternalChannelz()
-
-
Method Details
-
instance
-
addServer
Adds a server. -
addSubchannel
Adds a subchannel. -
addRootChannel
Adds a root channel. -
addClientSocket
Adds a socket. -
addListenSocket
-
addServerSocket
public void addServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket) Adds a server socket. -
removeServer
Removes a server. -
removeSubchannel
-
removeRootChannel
-
removeClientSocket
-
removeListenSocket
-
removeServerSocket
public void removeServerSocket(InternalInstrumented<InternalChannelz.ServerStats> server, InternalInstrumented<InternalChannelz.SocketStats> socket) Removes a server socket. -
getRootChannels
Returns aInternalChannelz.RootChannelList
. -
getChannel
Returns a channel. -
getSubchannel
Returns a subchannel. -
getServers
Returns a server list. -
getServer
Returns a server. -
getServerSockets
@Nullable public InternalChannelz.ServerSocketsList getServerSockets(long serverId, long fromId, int maxPageSize) Returns socket refs for a server. -
getSocket
Returns a socket. -
getServerSocket
-
containsServer
-
containsSubchannel
-
getRootChannel
-
containsClientSocket
-
add
-
remove
-
contains
private static <T extends InternalInstrumented<?>> boolean contains(Map<Long, T> map, InternalLogId id) -
id
Unwraps aInternalLogId
to return along
.
-