Package io.grpc.netty
Class Utils
java.lang.Object
io.grpc.netty.Utils
Common utility methods.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static final class
private static final class
private static final class
private static enum
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final io.netty.util.AsciiString
static final io.netty.util.AsciiString
static final SharedResourceHolder.Resource
<io.netty.channel.EventLoopGroup> static final Class
<? extends io.netty.channel.Channel> static final io.netty.channel.ChannelFactory
<? extends io.netty.channel.ServerChannel> static final SharedResourceHolder.Resource
<io.netty.channel.EventLoopGroup> static final Class
<? extends io.netty.channel.Channel> private static final Constructor
<? extends io.netty.channel.EventLoopGroup> static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
private static final Logger
static final SharedResourceHolder.Resource
<io.netty.channel.EventLoopGroup> static final SharedResourceHolder.Resource
<io.netty.channel.EventLoopGroup> static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
static final io.netty.util.AsciiString
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static byte[]
bytes
(CharSequence seq) static io.netty.handler.codec.http2.Http2Headers
convertClientHeaders
(Metadata headers, io.netty.util.AsciiString scheme, io.netty.util.AsciiString defaultPath, io.netty.util.AsciiString authority, io.netty.util.AsciiString method, io.netty.util.AsciiString userAgent) static Metadata
convertHeaders
(io.netty.handler.codec.http2.Http2Headers http2Headers) private static byte[][]
convertHeadersToArray
(io.netty.handler.codec.http2.Http2Headers http2Headers) static io.netty.handler.codec.http2.Http2Headers
convertServerHeaders
(Metadata headers) static io.netty.handler.codec.http2.Http2Headers
convertTrailers
(Metadata trailers, boolean headersSent) static Metadata
convertTrailers
(io.netty.handler.codec.http2.Http2Headers http2Headers) private static io.netty.buffer.ByteBufAllocator
createByteBufAllocator
(boolean preferDirect) private static io.netty.channel.EventLoopGroup
createEpollEventLoopGroup
(int parallelism, ThreadFactory threadFactory) private static Class
<? extends io.netty.channel.Channel> private static Class
<? extends io.netty.channel.Channel> private static Constructor
<? extends io.netty.channel.EventLoopGroup> private static Class
<? extends io.netty.channel.ServerChannel> static io.netty.buffer.ByteBufAllocator
getByteBufAllocator
(boolean forceHeapBuffer) private static <T> io.netty.channel.ChannelOption
<T> getEpollChannelOption
(String optionName) private static Throwable
(package private) static InternalChannelz.SocketOptions
getSocketOptions
(io.netty.channel.Channel channel) (package private) static boolean
(package private) static io.netty.channel.ChannelOption
<Integer> Returns TCP_USER_TIMEOUT channel option for Epoll channel if Epoll is available, otherwise null.private static io.netty.channel.ChannelFactory
<io.netty.channel.ServerChannel> static Status
-
Field Details
-
logger
-
STATUS_OK
public static final io.netty.util.AsciiString STATUS_OK -
HTTP_METHOD
public static final io.netty.util.AsciiString HTTP_METHOD -
HTTP_GET_METHOD
public static final io.netty.util.AsciiString HTTP_GET_METHOD -
HTTPS
public static final io.netty.util.AsciiString HTTPS -
HTTP
public static final io.netty.util.AsciiString HTTP -
CONTENT_TYPE_HEADER
public static final io.netty.util.AsciiString CONTENT_TYPE_HEADER -
CONTENT_TYPE_GRPC
public static final io.netty.util.AsciiString CONTENT_TYPE_GRPC -
TE_HEADER
public static final io.netty.util.AsciiString TE_HEADER -
TE_TRAILERS
public static final io.netty.util.AsciiString TE_TRAILERS -
USER_AGENT
public static final io.netty.util.AsciiString USER_AGENT -
NIO_BOSS_EVENT_LOOP_GROUP
public static final SharedResourceHolder.Resource<io.netty.channel.EventLoopGroup> NIO_BOSS_EVENT_LOOP_GROUP -
NIO_WORKER_EVENT_LOOP_GROUP
public static final SharedResourceHolder.Resource<io.netty.channel.EventLoopGroup> NIO_WORKER_EVENT_LOOP_GROUP -
DEFAULT_BOSS_EVENT_LOOP_GROUP
public static final SharedResourceHolder.Resource<io.netty.channel.EventLoopGroup> DEFAULT_BOSS_EVENT_LOOP_GROUP -
DEFAULT_WORKER_EVENT_LOOP_GROUP
public static final SharedResourceHolder.Resource<io.netty.channel.EventLoopGroup> DEFAULT_WORKER_EVENT_LOOP_GROUP -
DEFAULT_SERVER_CHANNEL_FACTORY
public static final io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> DEFAULT_SERVER_CHANNEL_FACTORY -
DEFAULT_CLIENT_CHANNEL_TYPE
-
EPOLL_DOMAIN_CLIENT_CHANNEL_TYPE
-
EPOLL_EVENT_LOOP_GROUP_CONSTRUCTOR
@Nullable private static final Constructor<? extends io.netty.channel.EventLoopGroup> EPOLL_EVENT_LOOP_GROUP_CONSTRUCTOR
-
-
Constructor Details
-
Utils
private Utils()
-
-
Method Details
-
getByteBufAllocator
public static io.netty.buffer.ByteBufAllocator getByteBufAllocator(boolean forceHeapBuffer) -
createByteBufAllocator
private static io.netty.buffer.ByteBufAllocator createByteBufAllocator(boolean preferDirect) -
convertHeaders
-
convertHeadersToArray
@CheckReturnValue private static byte[][] convertHeadersToArray(io.netty.handler.codec.http2.Http2Headers http2Headers) -
bytes
-
convertClientHeaders
public static io.netty.handler.codec.http2.Http2Headers convertClientHeaders(Metadata headers, io.netty.util.AsciiString scheme, io.netty.util.AsciiString defaultPath, io.netty.util.AsciiString authority, io.netty.util.AsciiString method, io.netty.util.AsciiString userAgent) -
convertServerHeaders
-
convertTrailers
-
convertTrailers
public static io.netty.handler.codec.http2.Http2Headers convertTrailers(Metadata trailers, boolean headersSent) -
statusFromThrowable
-
isEpollAvailable
static boolean isEpollAvailable() -
epollChannelType
-
epollDomainSocketChannelType
-
epollEventLoopGroupConstructor
private static Constructor<? extends io.netty.channel.EventLoopGroup> epollEventLoopGroupConstructor() -
epollServerChannelType
-
createEpollEventLoopGroup
private static io.netty.channel.EventLoopGroup createEpollEventLoopGroup(int parallelism, ThreadFactory threadFactory) -
nioServerChannelFactory
private static io.netty.channel.ChannelFactory<io.netty.channel.ServerChannel> nioServerChannelFactory() -
maybeGetTcpUserTimeoutOption
Returns TCP_USER_TIMEOUT channel option for Epoll channel if Epoll is available, otherwise null. -
getEpollChannelOption
-
getSocketOptions
-