io.netty.handler.codec.http2

Class Http2OutboundFrameLogger

java.lang.Object

io.netty.handler.codec.http2.Http2OutboundFrameLogger

All Implemented Interfaces:

io.netty.handler.codec.http2.Http2DataWriter, io.netty.handler.codec.http2.Http2FrameWriter, Closeable, AutoCloseable

@UnstableApi
public class Http2OutboundFrameLogger
extends Object
implements io.netty.handler.codec.http2.Http2FrameWriter

Decorator around a Http2FrameWriter that logs all outbound frames before calling the writer.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.handler.codec.http2.Http2FrameWriter

io.netty.handler.codec.http2.Http2FrameWriter.Configuration

Field Summary

Fields

Modifier and Type	Field and Description
static io.prometheus.client.Histogram	writeHeaderLogDuration

Constructor Summary

Constructors

Constructor and Description
Http2OutboundFrameLogger(io.netty.handler.codec.http2.Http2FrameWriter writer, io.netty.handler.codec.http2.Http2FrameLogger logger)

Method Summary

Modifier and Type	Method and Description
void	close()
io.netty.handler.codec.http2.Http2FrameWriter.Configuration	configuration()
io.netty.channel.ChannelFuture	writeData(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeFrame(io.netty.channel.ChannelHandlerContext ctx, byte frameType, int streamId, io.netty.handler.codec.http2.Http2Flags flags, io.netty.buffer.ByteBuf payload, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeGoAway(io.netty.channel.ChannelHandlerContext ctx, int lastStreamId, long errorCode, io.netty.buffer.ByteBuf debugData, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writePing(io.netty.channel.ChannelHandlerContext ctx, boolean ack, long data, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writePriority(io.netty.channel.ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writePushPromise(io.netty.channel.ChannelHandlerContext ctx, int streamId, int promisedStreamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeRstStream(io.netty.channel.ChannelHandlerContext ctx, int streamId, long errorCode, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeSettings(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http2.Http2Settings settings, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeSettingsAck(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeWindowUpdate(io.netty.channel.ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, io.netty.channel.ChannelPromise promise)

Methods inherited from class java.lang.Object

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

Field Detail

writeHeaderLogDuration

public static final io.prometheus.client.Histogram writeHeaderLogDuration

Constructor Detail

Http2OutboundFrameLogger

public Http2OutboundFrameLogger(io.netty.handler.codec.http2.Http2FrameWriter writer,
                                io.netty.handler.codec.http2.Http2FrameLogger logger)

Method Detail

writeData

public io.netty.channel.ChannelFuture writeData(io.netty.channel.ChannelHandlerContext ctx,
                                                int streamId,
                                                io.netty.buffer.ByteBuf data,
                                                int padding,
                                                boolean endStream,
                                                io.netty.channel.ChannelPromise promise)

Specified by:

writeData in interface io.netty.handler.codec.http2.Http2DataWriter

writeHeaders

public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx,
                                                   int streamId,
                                                   io.netty.handler.codec.http2.Http2Headers headers,
                                                   int padding,
                                                   boolean endStream,
                                                   io.netty.channel.ChannelPromise promise)

Specified by:

writeHeaders in interface io.netty.handler.codec.http2.Http2FrameWriter

writeHeaders

public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx,
                                                   int streamId,
                                                   io.netty.handler.codec.http2.Http2Headers headers,
                                                   int streamDependency,
                                                   short weight,
                                                   boolean exclusive,
                                                   int padding,
                                                   boolean endStream,
                                                   io.netty.channel.ChannelPromise promise)

Specified by:

writeHeaders in interface io.netty.handler.codec.http2.Http2FrameWriter

writePriority

public io.netty.channel.ChannelFuture writePriority(io.netty.channel.ChannelHandlerContext ctx,
                                                    int streamId,
                                                    int streamDependency,
                                                    short weight,
                                                    boolean exclusive,
                                                    io.netty.channel.ChannelPromise promise)

Specified by:

writePriority in interface io.netty.handler.codec.http2.Http2FrameWriter

writeRstStream

public io.netty.channel.ChannelFuture writeRstStream(io.netty.channel.ChannelHandlerContext ctx,
                                                     int streamId,
                                                     long errorCode,
                                                     io.netty.channel.ChannelPromise promise)

Specified by:

writeRstStream in interface io.netty.handler.codec.http2.Http2FrameWriter

writeSettings

public io.netty.channel.ChannelFuture writeSettings(io.netty.channel.ChannelHandlerContext ctx,
                                                    io.netty.handler.codec.http2.Http2Settings settings,
                                                    io.netty.channel.ChannelPromise promise)

Specified by:

writeSettings in interface io.netty.handler.codec.http2.Http2FrameWriter

writeSettingsAck

public io.netty.channel.ChannelFuture writeSettingsAck(io.netty.channel.ChannelHandlerContext ctx,
                                                       io.netty.channel.ChannelPromise promise)

Specified by:

writeSettingsAck in interface io.netty.handler.codec.http2.Http2FrameWriter

writePing

public io.netty.channel.ChannelFuture writePing(io.netty.channel.ChannelHandlerContext ctx,
                                                boolean ack,
                                                long data,
                                                io.netty.channel.ChannelPromise promise)

Specified by:

writePing in interface io.netty.handler.codec.http2.Http2FrameWriter

writePushPromise

public io.netty.channel.ChannelFuture writePushPromise(io.netty.channel.ChannelHandlerContext ctx,
                                                       int streamId,
                                                       int promisedStreamId,
                                                       io.netty.handler.codec.http2.Http2Headers headers,
                                                       int padding,
                                                       io.netty.channel.ChannelPromise promise)

Specified by:

writePushPromise in interface io.netty.handler.codec.http2.Http2FrameWriter

writeGoAway

public io.netty.channel.ChannelFuture writeGoAway(io.netty.channel.ChannelHandlerContext ctx,
                                                  int lastStreamId,
                                                  long errorCode,
                                                  io.netty.buffer.ByteBuf debugData,
                                                  io.netty.channel.ChannelPromise promise)

Specified by:

writeGoAway in interface io.netty.handler.codec.http2.Http2FrameWriter

writeWindowUpdate

public io.netty.channel.ChannelFuture writeWindowUpdate(io.netty.channel.ChannelHandlerContext ctx,
                                                        int streamId,
                                                        int windowSizeIncrement,
                                                        io.netty.channel.ChannelPromise promise)

Specified by:

writeWindowUpdate in interface io.netty.handler.codec.http2.Http2FrameWriter

writeFrame

public io.netty.channel.ChannelFuture writeFrame(io.netty.channel.ChannelHandlerContext ctx,
                                                 byte frameType,
                                                 int streamId,
                                                 io.netty.handler.codec.http2.Http2Flags flags,
                                                 io.netty.buffer.ByteBuf payload,
                                                 io.netty.channel.ChannelPromise promise)

Specified by:

writeFrame in interface io.netty.handler.codec.http2.Http2FrameWriter

close

public void close()

Specified by:

close in interface io.netty.handler.codec.http2.Http2FrameWriter

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

configuration

public io.netty.handler.codec.http2.Http2FrameWriter.Configuration configuration()

Specified by:

configuration in interface io.netty.handler.codec.http2.Http2FrameWriter