Class ChannelzProtoUtil

java.lang.Object

io.grpc.protobuf.services.ChannelzProtoUtil

final class ChannelzProtoUtil
extends Object

A static utility class for turning internal data structures into protos.

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	logger
static final String	SO_LINGER
static final String	SO_TIMEOUT
static final String	TCP_INFO

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ChannelzProtoUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static ChannelData	extractChannelData(InternalChannelz.ChannelStats stats)
(package private) static SocketData	extractSocketData(InternalChannelz.SocketStats socketStats)
private static <T> T	getFuture(com.google.common.util.concurrent.ListenableFuture<T> future)
(package private) static Address	toAddress(SocketAddress address)
(package private) static Channel	toChannel(InternalInstrumented<InternalChannelz.ChannelStats> channel)
(package private) static ChannelConnectivityState	toChannelConnectivityState(ConnectivityState s)
(package private) static ChannelRef	toChannelRef(InternalWithLogId obj)
private static ChannelTrace	toChannelTrace(InternalChannelz.ChannelTrace channelTrace)
private static List<ChannelTraceEvent>	toChannelTraceEvents(List<InternalChannelz.ChannelTrace.Event> events)
(package private) static GetServerSocketsResponse	toGetServerSocketsResponse(InternalChannelz.ServerSocketsList serverSockets)
(package private) static GetServersResponse	toGetServersResponse(InternalChannelz.ServerList servers)
(package private) static GetTopChannelsResponse	toGetTopChannelResponse(InternalChannelz.RootChannelList rootChannels)
(package private) static Security	toSecurity(InternalChannelz.Security security)
(package private) static Server	toServer(InternalInstrumented<InternalChannelz.ServerStats> obj)
(package private) static ServerData	toServerData(InternalChannelz.ServerStats stats)
(package private) static ServerRef	toServerRef(InternalWithLogId obj)
(package private) static Socket	toSocket(InternalInstrumented<InternalChannelz.SocketStats> obj)
(package private) static SocketOption	toSocketOptionAdditional(String name, String value)
(package private) static SocketOption	toSocketOptionLinger(int lingerSeconds)
(package private) static List<SocketOption>	toSocketOptionsList(InternalChannelz.SocketOptions options)
(package private) static SocketOption	toSocketOptionTcpInfo(InternalChannelz.TcpInfo i)
(package private) static SocketOption	toSocketOptionTimeout(String name, int timeoutMillis)
(package private) static SocketRef	toSocketRef(InternalWithLogId obj)
(package private) static ChannelConnectivityState.State	toState(ConnectivityState state)
(package private) static Subchannel	toSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)
(package private) static SubchannelRef	toSubchannelRef(InternalWithLogId obj)

Methods inherited from class Object

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

Field Details

logger

private static final Logger logger

SO_LINGER

public static final String SO_LINGER

See Also:

• Constant Field Values

SO_TIMEOUT

public static final String SO_TIMEOUT

See Also:

• Constant Field Values

TCP_INFO

public static final String TCP_INFO

See Also:

• Constant Field Values

Constructor Details

ChannelzProtoUtil

private ChannelzProtoUtil()

Method Details

toChannelRef

static ChannelRef toChannelRef(InternalWithLogId obj)

toSubchannelRef

static SubchannelRef toSubchannelRef(InternalWithLogId obj)

toServerRef

static ServerRef toServerRef(InternalWithLogId obj)

toSocketRef

static SocketRef toSocketRef(InternalWithLogId obj)

toServer

static Server toServer(InternalInstrumented<InternalChannelz.ServerStats> obj)

toServerData

static ServerData toServerData(InternalChannelz.ServerStats stats)

toSecurity

static Security toSecurity(InternalChannelz.Security security)

toSocket

static Socket toSocket(InternalInstrumented<InternalChannelz.SocketStats> obj)

toAddress

static Address toAddress(SocketAddress address)

extractSocketData

static SocketData extractSocketData(InternalChannelz.SocketStats socketStats)

toSocketOptionLinger

static SocketOption toSocketOptionLinger(int lingerSeconds)

toSocketOptionTimeout

static SocketOption toSocketOptionTimeout(String name,
 int timeoutMillis)

toSocketOptionTcpInfo

static SocketOption toSocketOptionTcpInfo(InternalChannelz.TcpInfo i)

toSocketOptionAdditional

static SocketOption toSocketOptionAdditional(String name,
 String value)

toSocketOptionsList

static List<SocketOption> toSocketOptionsList(InternalChannelz.SocketOptions options)

toChannel

static Channel toChannel(InternalInstrumented<InternalChannelz.ChannelStats> channel)

extractChannelData

static ChannelData extractChannelData(InternalChannelz.ChannelStats stats)

toChannelConnectivityState

static ChannelConnectivityState toChannelConnectivityState(ConnectivityState s)

toChannelTrace

private static ChannelTrace toChannelTrace(InternalChannelz.ChannelTrace channelTrace)

toChannelTraceEvents

private static List<ChannelTraceEvent> toChannelTraceEvents(List<InternalChannelz.ChannelTrace.Event> events)

toState

static ChannelConnectivityState.State toState(ConnectivityState state)

toSubchannel

static Subchannel toSubchannel(InternalInstrumented<InternalChannelz.ChannelStats> subchannel)

toGetTopChannelResponse

static GetTopChannelsResponse toGetTopChannelResponse(InternalChannelz.RootChannelList rootChannels)

toGetServersResponse

static GetServersResponse toGetServersResponse(InternalChannelz.ServerList servers)

toGetServerSocketsResponse

static GetServerSocketsResponse toGetServerSocketsResponse(InternalChannelz.ServerSocketsList serverSockets)

getFuture

private static <T> T getFuture(com.google.common.util.concurrent.ListenableFuture<T> future)