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 specific MethodDescriptor.

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

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)

Methods inherited from class java.lang.Object

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

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)

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(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)