Package io.grpc.protobuf.services
Class BinlogHelper
- java.lang.Object
-
- io.grpc.protobuf.services.BinlogHelper
-
@ThreadSafe final class BinlogHelper extends java.lang.Object
A binary log class that is configured for a specificMethodDescriptor
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static interface
BinlogHelper.Factory
(package private) static class
BinlogHelper.FactoryImpl
(package private) static class
BinlogHelper.MaybeTruncated<T>
(package private) static class
BinlogHelper.SinkWriter
(package private) static class
BinlogHelper.SinkWriterImpl
(package private) static interface
BinlogHelper.TimeProvider
-
Field Summary
Fields Modifier and Type Field Description private static java.util.Set<java.lang.String>
ALWAYS_INCLUDED_METADATA
private static java.util.logging.Logger
logger
private static java.util.Set<java.lang.String>
NEVER_INCLUDED_METADATA
(package private) static Metadata.Key<byte[]>
STATUS_DETAILS_KEY
(package private) BinlogHelper.SinkWriter
writer
-
Constructor Summary
Constructors Constructor Description BinlogHelper(BinlogHelper.SinkWriter writer)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) static BinlogHelper.MaybeTruncated<Message.Builder>
createMessageProto(byte[] message, int maxMessageBytes)
(package private) static BinlogHelper.MaybeTruncated<Metadata.Builder>
createMetadataProto(Metadata metadata, int maxHeaderBytes)
ClientInterceptor
getClientInterceptor(long callId)
(package private) static java.net.SocketAddress
getPeerSocket(Attributes streamAttributes)
ServerInterceptor
getServerInterceptor(long callId)
private static Deadline
min(Deadline deadline0, Deadline deadline1)
(package private) static Address
socketToProto(java.net.SocketAddress address)
-
-
-
Field Detail
-
logger
private static final java.util.logging.Logger logger
-
STATUS_DETAILS_KEY
static final Metadata.Key<byte[]> STATUS_DETAILS_KEY
-
writer
final BinlogHelper.SinkWriter writer
-
NEVER_INCLUDED_METADATA
private static final java.util.Set<java.lang.String> NEVER_INCLUDED_METADATA
-
ALWAYS_INCLUDED_METADATA
private static final java.util.Set<java.lang.String> ALWAYS_INCLUDED_METADATA
-
-
Constructor Detail
-
BinlogHelper
BinlogHelper(BinlogHelper.SinkWriter writer)
-
-
Method Detail
-
getPeerSocket
static java.net.SocketAddress getPeerSocket(Attributes streamAttributes)
-
getClientInterceptor
public ClientInterceptor getClientInterceptor(long callId)
-
getServerInterceptor
public ServerInterceptor getServerInterceptor(long callId)
-
socketToProto
static Address socketToProto(java.net.SocketAddress address)
-
createMetadataProto
static BinlogHelper.MaybeTruncated<Metadata.Builder> createMetadataProto(Metadata metadata, int maxHeaderBytes)
-
createMessageProto
static BinlogHelper.MaybeTruncated<Message.Builder> createMessageProto(byte[] message, int maxMessageBytes)
-
-