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 Object
  • 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

      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.