Package io.grpc.protobuf.services
Class BinlogHelper
java.lang.Object
io.grpc.protobuf.services.BinlogHelper
A binary log class that is configured for a specific
MethodDescriptor
.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static interface
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static interface
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final Logger
(package private) static final Metadata.Key
<byte[]> (package private) final BinlogHelper.SinkWriter
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) static BinlogHelper.MaybeTruncated
<Message.Builder> createMessageProto
(byte[] message, int maxMessageBytes) (package private) static BinlogHelper.MaybeTruncated
<Metadata.Builder> createMetadataProto
(Metadata metadata, int maxHeaderBytes) getClientInterceptor
(long callId) (package private) static SocketAddress
getPeerSocket
(Attributes streamAttributes) getServerInterceptor
(long callId) private static Deadline
(package private) static Address
socketToProto
(SocketAddress address)
-
Field Details
-
logger
-
STATUS_DETAILS_KEY
-
writer
-
NEVER_INCLUDED_METADATA
-
ALWAYS_INCLUDED_METADATA
-
-
Constructor Details
-
BinlogHelper
BinlogHelper(BinlogHelper.SinkWriter writer)
-
-
Method Details
-
getPeerSocket
-
min
-
getClientInterceptor
-
getServerInterceptor
-
socketToProto
-
createMetadataProto
static BinlogHelper.MaybeTruncated<Metadata.Builder> createMetadataProto(Metadata metadata, int maxHeaderBytes) -
createMessageProto
static BinlogHelper.MaybeTruncated<Message.Builder> createMessageProto(byte[] message, int maxMessageBytes)
-