Package io.grpc.protobuf.services

Class BinlogHelper

java.lang.Object

io.grpc.protobuf.services.BinlogHelper

@ThreadSafe
final class BinlogHelper
extends Object

A binary log class that is configured for a specific MethodDescriptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	BinlogHelper.Factory
(package private) static final class	BinlogHelper.FactoryImpl
(package private) static final class	BinlogHelper.MaybeTruncated<T>
(package private) static class	BinlogHelper.SinkWriter
(package private) static final class	BinlogHelper.SinkWriterImpl
(package private) static interface	BinlogHelper.TimeProvider

Field Summary

Fields

Modifier and Type	Field	Description
private static final Set<String>	ALWAYS_INCLUDED_METADATA
private static final Logger	logger
private static final Set<String>	NEVER_INCLUDED_METADATA
(package private) static final Metadata.Key<byte[]>	STATUS_DETAILS_KEY
(package private) final BinlogHelper.SinkWriter	writer

Constructor Summary

Constructors

Constructor	Description
BinlogHelper(BinlogHelper.SinkWriter writer)

Method Summary

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 SocketAddress	getPeerSocket(Attributes streamAttributes)
ServerInterceptor	getServerInterceptor(long callId)
private static Deadline	min(Deadline deadline0, Deadline deadline1)
(package private) static Address	socketToProto(SocketAddress address)

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final Logger logger

STATUS_DETAILS_KEY

static final Metadata.Key<byte[]> STATUS_DETAILS_KEY

writer

final BinlogHelper.SinkWriter writer

NEVER_INCLUDED_METADATA

private static final Set<String> NEVER_INCLUDED_METADATA

ALWAYS_INCLUDED_METADATA

private static final Set<String> ALWAYS_INCLUDED_METADATA

Constructor Details

BinlogHelper

BinlogHelper(BinlogHelper.SinkWriter writer)

Method Details

getPeerSocket

static SocketAddress getPeerSocket(Attributes streamAttributes)

min

private static Deadline min(@Nullable
 Deadline deadline0,
 @Nullable
 Deadline deadline1)

getClientInterceptor

public ClientInterceptor getClientInterceptor(long callId)

getServerInterceptor

public ServerInterceptor getServerInterceptor(long callId)

socketToProto

static Address socketToProto(SocketAddress address)

createMetadataProto

static BinlogHelper.MaybeTruncated<Metadata.Builder> createMetadataProto(Metadata metadata,
 int maxHeaderBytes)

createMessageProto

static BinlogHelper.MaybeTruncated<Message.Builder> createMessageProto(byte[] message,
 int maxMessageBytes)