Class BinlogHelper.SinkWriter

    • Constructor Detail

      • SinkWriter

        SinkWriter()
    • 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.
      • 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.