Package io.grpc
Class InternalChannelz
- java.lang.Object
-
- io.grpc.InternalChannelz
-
@Internal public final class InternalChannelz extends java.lang.Object
This is an internal API. Do NOT use.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
InternalChannelz.ChannelStats
A data class to represent a channel's stats.static class
InternalChannelz.ChannelTrace
static class
InternalChannelz.OtherSecurity
static class
InternalChannelz.RootChannelList
static class
InternalChannelz.Security
static class
InternalChannelz.ServerList
private static class
InternalChannelz.ServerSocketMap
static class
InternalChannelz.ServerSocketsList
static class
InternalChannelz.ServerStats
static class
InternalChannelz.SocketOptions
static class
InternalChannelz.SocketStats
static class
InternalChannelz.TcpInfo
static class
InternalChannelz.Tls
static class
InternalChannelz.TransportStats
A data class to represent transport stats.
-
Field Summary
Fields Modifier and Type Field Description private static InternalChannelz
INSTANCE
private static java.util.logging.Logger
log
private java.util.concurrent.ConcurrentMap<java.lang.Long,InternalInstrumented<InternalChannelz.SocketStats>>
otherSockets
private java.util.concurrent.ConcurrentMap<java.lang.Long,InternalChannelz.ServerSocketMap>
perServerSockets
private java.util.concurrent.ConcurrentNavigableMap<java.lang.Long,InternalInstrumented<InternalChannelz.ChannelStats>>
rootChannels
private java.util.concurrent.ConcurrentNavigableMap<java.lang.Long,InternalInstrumented<InternalChannelz.ServerStats>>
servers
private java.util.concurrent.ConcurrentMap<java.lang.Long,InternalInstrumented<InternalChannelz.ChannelStats>>
subchannels
-
Constructor Summary
Constructors Constructor Description InternalChannelz()
-
Method Summary
-
-
-
Field Detail
-
log
private static final java.util.logging.Logger log
-
INSTANCE
private static final InternalChannelz INSTANCE
-
servers
private final java.util.concurrent.ConcurrentNavigableMap<java.lang.Long,InternalInstrumented<InternalChannelz.ServerStats>> servers
-
rootChannels
private final java.util.concurrent.ConcurrentNavigableMap<java.lang.Long,InternalInstrumented<InternalChannelz.ChannelStats>> rootChannels
-
subchannels
private final java.util.concurrent.ConcurrentMap<java.lang.Long,InternalInstrumented<InternalChannelz.ChannelStats>> subchannels
-
otherSockets
private final java.util.concurrent.ConcurrentMap<java.lang.Long,InternalInstrumented<InternalChannelz.SocketStats>> otherSockets
-
perServerSockets
private final java.util.concurrent.ConcurrentMap<java.lang.Long,InternalChannelz.ServerSocketMap> perServerSockets
-
-
Method Detail
-
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 aInternalChannelz.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(java.util.Map<java.lang.Long,T> map, T object)
-
remove
private static <T extends InternalInstrumented<?>> void remove(java.util.Map<java.lang.Long,T> map, T object)
-
contains
private static <T extends InternalInstrumented<?>> boolean contains(java.util.Map<java.lang.Long,T> map, InternalLogId id)
-
id
public static long id(InternalWithLogId withLogId)
Unwraps aInternalLogId
to return along
.
-
-