Class BinlogHelper.SinkWriterImpl

java.lang.Object

io.grpc.protobuf.services.BinlogHelper.SinkWriter

io.grpc.protobuf.services.BinlogHelper.SinkWriterImpl

Enclosing class:

BinlogHelper

static final class BinlogHelper.SinkWriterImpl
extends BinlogHelper.SinkWriter

Field Summary

Fields

Modifier and Type	Field	Description
private final int	maxHeaderBytes
private final int	maxMessageBytes
private final BinaryLogSink	sink
private BinlogHelper.TimeProvider	timeProvider

Constructor Summary

Constructors

Constructor	Description
SinkWriterImpl(BinaryLogSink sink, BinlogHelper.TimeProvider timeProvider, int maxHeaderBytes, int maxMessageBytes)

Method Summary

Modifier and Type	Method	Description
(package private) int	getMaxHeaderBytes()	Returns the number bytes of the header this writer will log, according to configuration.
(package private) int	getMaxMessageBytes()	Returns the number bytes of the message this writer will log, according to configuration.
(package private) void	logCancel(long seq, GrpcLogEntry.Logger logger, long callId)	Logs the cancellation.
(package private) void	logClientHeader(long seq, String methodName, String authority, com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress)	Logs the client header.
(package private) void	logHalfClose(long seq, GrpcLogEntry.Logger logger, long callId)
(package private) <T> void	logRpcMessage(long seq, GrpcLogEntry.EventType eventType, MethodDescriptor.Marshaller<T> marshaller, T message, GrpcLogEntry.Logger logger, long callId)	Logs the message message.
(package private) void	logServerHeader(long seq, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress)	Logs the server header.
(package private) void	logTrailer(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress)	Logs the server trailer.
(package private) GrpcLogEntry.Builder	newTimestampedBuilder()

Methods inherited from class Object

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

Field Details

sink

private final BinaryLogSink sink

timeProvider

private BinlogHelper.TimeProvider timeProvider

maxHeaderBytes

private final int maxHeaderBytes

maxMessageBytes

private final int maxMessageBytes

Constructor Details

SinkWriterImpl

SinkWriterImpl(BinaryLogSink sink,
 BinlogHelper.TimeProvider timeProvider,
 int maxHeaderBytes,
 int maxMessageBytes)

Method Details

newTimestampedBuilder

GrpcLogEntry.Builder newTimestampedBuilder()

logClientHeader

void logClientHeader(long seq,
 String methodName,
 @Nullable
 String authority,
 @Nullable
 com.google.protobuf.Duration timeout,
 Metadata metadata,
 GrpcLogEntry.Logger logger,
 long callId,
 @Nullable
 SocketAddress peerAddress)

Description copied from class: BinlogHelper.SinkWriter

Logs the client header. This method logs the appropriate number of bytes as determined by the binary logging configuration.

Specified by:

logClientHeader in class BinlogHelper.SinkWriter

logServerHeader

void logServerHeader(long seq,
 Metadata metadata,
 GrpcLogEntry.Logger logger,
 long callId,
 @Nullable
 SocketAddress peerAddress)

Description copied from class: BinlogHelper.SinkWriter

Logs the server header. This method logs the appropriate number of bytes as determined by the binary logging configuration.

Specified by:

logServerHeader in class BinlogHelper.SinkWriter

logTrailer

void logTrailer(long seq,
 Status status,
 Metadata metadata,
 GrpcLogEntry.Logger logger,
 long callId,
 @Nullable
 SocketAddress peerAddress)

Description copied from class: BinlogHelper.SinkWriter

Logs the server trailer. This method logs the appropriate number of bytes as determined by the binary logging configuration.

Specified by:

logTrailer in class BinlogHelper.SinkWriter

logRpcMessage

<T> void logRpcMessage(long seq,
 GrpcLogEntry.EventType eventType,
 MethodDescriptor.Marshaller<T> marshaller,
 T message,
 GrpcLogEntry.Logger logger,
 long callId)

Description copied from class: BinlogHelper.SinkWriter

Logs the message message. The number of bytes logged is determined by the binary logging configuration.

Specified by:

logRpcMessage in class BinlogHelper.SinkWriter

logHalfClose

void logHalfClose(long seq,
 GrpcLogEntry.Logger logger,
 long callId)

Specified by:

logHalfClose in class BinlogHelper.SinkWriter

logCancel

void logCancel(long seq,
 GrpcLogEntry.Logger logger,
 long callId)

Description copied from class: BinlogHelper.SinkWriter

Logs the cancellation.

Specified by:

logCancel in class BinlogHelper.SinkWriter

getMaxHeaderBytes

int getMaxHeaderBytes()

Description copied from class: BinlogHelper.SinkWriter

Returns the number bytes of the header this writer will log, according to configuration.

Specified by:

getMaxHeaderBytes in class BinlogHelper.SinkWriter

getMaxMessageBytes

int getMaxMessageBytes()

Description copied from class: BinlogHelper.SinkWriter

Returns the number bytes of the message this writer will log, according to configuration.

Specified by:

getMaxMessageBytes in class BinlogHelper.SinkWriter