Package io.grpc.protobuf.services
Class BinlogHelper.SinkWriter
- java.lang.Object
-
- io.grpc.protobuf.services.BinlogHelper.SinkWriter
-
- Direct Known Subclasses:
BinlogHelper.SinkWriterImpl
- Enclosing class:
- BinlogHelper
abstract static class BinlogHelper.SinkWriter extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description SinkWriter()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description (package private) abstract int
getMaxHeaderBytes()
Returns the number bytes of the header this writer will log, according to configuration.(package private) abstract int
getMaxMessageBytes()
Returns the number bytes of the message this writer will log, according to configuration.(package private) abstract void
logCancel(long seq, GrpcLogEntry.Logger logger, long callId)
Logs the cancellation.(package private) abstract void
logClientHeader(long seq, java.lang.String methodName, java.lang.String authority, com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, java.net.SocketAddress peerAddress)
Logs the client header.(package private) abstract void
logHalfClose(long seq, GrpcLogEntry.Logger logger, long callId)
(package private) abstract <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) abstract void
logServerHeader(long seq, Metadata metadata, GrpcLogEntry.Logger logger, long callId, java.net.SocketAddress peerAddress)
Logs the server header.(package private) abstract void
logTrailer(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, java.net.SocketAddress peerAddress)
Logs the server trailer.
-
-
-
Method Detail
-
logClientHeader
abstract void logClientHeader(long seq, java.lang.String methodName, @Nullable java.lang.String authority, @Nullable com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, @Nullable java.net.SocketAddress peerAddress)
Logs the client header. This method logs the appropriate number of bytes as determined by the binary logging configuration.
-
logServerHeader
abstract void logServerHeader(long seq, Metadata metadata, GrpcLogEntry.Logger logger, long callId, @Nullable java.net.SocketAddress peerAddress)
Logs the server header. This method logs the appropriate number of bytes as determined by the binary logging configuration.
-
logTrailer
abstract void logTrailer(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, @Nullable java.net.SocketAddress peerAddress)
Logs the server trailer. This method logs the appropriate number of bytes as determined by the binary logging configuration.
-
logRpcMessage
abstract <T> void logRpcMessage(long seq, GrpcLogEntry.EventType eventType, MethodDescriptor.Marshaller<T> marshaller, T message, GrpcLogEntry.Logger logger, long callId)
Logs the message message. The number of bytes logged is determined by the binary logging configuration.
-
logHalfClose
abstract void logHalfClose(long seq, GrpcLogEntry.Logger logger, long callId)
-
logCancel
abstract void logCancel(long seq, GrpcLogEntry.Logger logger, long callId)
Logs the cancellation.
-
getMaxHeaderBytes
abstract int getMaxHeaderBytes()
Returns the number bytes of the header this writer will log, according to configuration.
-
getMaxMessageBytes
abstract int getMaxMessageBytes()
Returns the number bytes of the message this writer will log, according to configuration.
-
-