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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) abstract int
Returns the number bytes of the header this writer will log, according to configuration.(package private) abstract int
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, String methodName, String authority, com.google.protobuf.Duration timeout, Metadata metadata, GrpcLogEntry.Logger logger, long callId, 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, SocketAddress peerAddress) Logs the server header.(package private) abstract void
logTrailer
(long seq, Status status, Metadata metadata, GrpcLogEntry.Logger logger, long callId, SocketAddress peerAddress) Logs the server trailer.
-
Constructor Details
-
SinkWriter
SinkWriter()
-
-
Method Details
-
logClientHeader
abstract 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) 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 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 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
-
logCancel
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.
-