HTTP functionality for the Reactor Netty library 1.1.16 · reactor.netty.http.server.AbstractHttpServerMetricsHandler

Field Summary

Modifier and Type	Field and Description
pack-priv boolean	channelActivated
pack-priv boolean	channelOpened
pack-priv long	dataReceived
pack-priv long	dataReceivedTime
pack-priv long	dataSent
pack-priv long	dataSentTime
pack-priv static final Function<String, String>	DEFAULT_METHOD_TAG_VALUE
private static final Logger	log
pack-priv final Function<String, String>	methodTagValue
pack-priv static final Set<String>	STANDARD_METHODS
pack-priv static final String	UNKNOWN_METHOD
pack-priv final Function<String, String>	uriTagValue

Access	Constructor and Description
protected	AbstractHttpServerMetricsHandler(Function<String, String> methodTagValue, Function<String, String> uriTagValue)
protected	AbstractHttpServerMetricsHandler(AbstractHttpServerMetricsHandler copy)

Access

Constructor and Description

protected

AbstractHttpServerMetricsHandler(Function<String, String> methodTagValue, Function<String, String> uriTagValue)

protected

AbstractHttpServerMetricsHandler(AbstractHttpServerMetricsHandler copy)

Modifier and Type	Method and Description
public void	channelActive(ChannelHandlerContext ctx) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelActive. Implements io.netty.channel.ChannelInboundHandler.channelActive. Calls `ChannelHandlerContext#fireChannelActive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`.
public void	channelInactive(ChannelHandlerContext ctx) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Implements io.netty.channel.ChannelInboundHandler.channelInactive. Calls `ChannelHandlerContext#fireChannelInactive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`.
public void	channelRead(ChannelHandlerContext ctx, Object msg) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Implements io.netty.channel.ChannelInboundHandler.channelRead. Calls `ChannelHandlerContext#fireChannelRead(Object)` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`.
public void	exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught. Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught. Gets called if a `Throwable` was thrown.
private long	extractProcessedDataFromBuffer(Object msg)
protected void	recordActiveConnection(SocketAddress localAddress)
protected void	recordClosedStream(SocketAddress localAddress)
protected abstract HttpServerMetricsRecorder	recorder()
protected void	recordException(HttpServerOperations ops, String path)
protected void	recordInactiveConnection(SocketAddress localAddress)
pack-priv void	recordInactiveConnectionOrStream(Channel channel)
protected void	recordOpenStream(SocketAddress localAddress)
protected void	recordRead(HttpServerOperations ops, String path, String method)
protected void	recordWrite(HttpServerOperations ops, String path, String method, String status)
protected void	startRead(HttpServerOperations ops, String path, String method)
protected void	startWrite(HttpServerOperations ops, String path, String method, String status)
public void	write(ChannelHandlerContext the `ChannelHandlerContext` for which the write operation is made ctx, Object the message to write msg, ChannelPromise the `ChannelPromise` to notify once the operation completes promise) Overrides io.netty.channel.ChannelDuplexHandler.write. Implements io.netty.channel.ChannelOutboundHandler.write. Calls `ChannelHandlerContext#write(Object, ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`.

Modifier and Type

Method and Description

public void

channelActive(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelActive.

Implements io.netty.channel.ChannelInboundHandler.channelActive.

Calls ChannelHandlerContext#fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline.

public void

channelInactive(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive.

Implements io.netty.channel.ChannelInboundHandler.channelInactive.

Calls ChannelHandlerContext#fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline.

public void

channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.

public void

exceptionCaught(ChannelHandlerContext ctx, Throwable cause)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught.

Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught.

Gets called if a Throwable was thrown.

private long

extractProcessedDataFromBuffer(Object msg)

protected void

recordActiveConnection(SocketAddress localAddress)

protected void

recordClosedStream(SocketAddress localAddress)

protected abstract HttpServerMetricsRecorder

recorder()

protected void

recordException(HttpServerOperations ops, String path)

protected void

recordInactiveConnection(SocketAddress localAddress)

pack-priv void

recordInactiveConnectionOrStream(Channel channel)

protected void

recordOpenStream(SocketAddress localAddress)

protected void

recordRead(HttpServerOperations ops, String path, String method)

protected void

recordWrite(HttpServerOperations ops, String path, String method, String status)

protected void

startRead(HttpServerOperations ops, String path, String method)

protected void

startWrite(HttpServerOperations ops, String path, String method, String status)

public void

write(ChannelHandlerContext

the ChannelHandlerContext for which the write operation is made

ctx, Object

the message to write

msg, ChannelPromise

the ChannelPromise to notify once the operation completes

promise)

Overrides io.netty.channel.ChannelDuplexHandler.write.

Implements io.netty.channel.ChannelOutboundHandler.write.

Calls ChannelHandlerContext#write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.

Field Detail

channelActivated	back to summary
pack-priv boolean channelActivated

channelActivated

back to summary

pack-priv boolean channelActivated

channelOpened	back to summary
pack-priv boolean channelOpened

channelOpened

back to summary

pack-priv boolean channelOpened

dataReceived	back to summary
pack-priv long dataReceived

dataReceived

back to summary

pack-priv long dataReceived

dataReceivedTime	back to summary
pack-priv long dataReceivedTime

dataReceivedTime

back to summary

pack-priv long dataReceivedTime

dataSent	back to summary
pack-priv long dataSent

dataSent

back to summary

pack-priv long dataSent

dataSentTime	back to summary
pack-priv long dataSentTime

dataSentTime

back to summary

pack-priv long dataSentTime

DEFAULT_METHOD_TAG_VALUE	back to summary
pack-priv static final Function<String, String> DEFAULT_METHOD_TAG_VALUE

DEFAULT_METHOD_TAG_VALUE

back to summary

pack-priv static final Function<String, String> DEFAULT_METHOD_TAG_VALUE

log	back to summary
private static final Logger log

log

back to summary

private static final Logger log

methodTagValue	back to summary
pack-priv final Function<String, String> methodTagValue

methodTagValue

back to summary

pack-priv final Function<String, String> methodTagValue

STANDARD_METHODS	back to summary
pack-priv static final Set<String> STANDARD_METHODS

STANDARD_METHODS

back to summary

pack-priv static final Set<String> STANDARD_METHODS

UNKNOWN_METHOD	back to summary
pack-priv static final String UNKNOWN_METHOD

UNKNOWN_METHOD

back to summary

pack-priv static final String UNKNOWN_METHOD

uriTagValue	back to summary
pack-priv final Function<String, String> uriTagValue

uriTagValue

back to summary

pack-priv final Function<String, String> uriTagValue

Constructor Detail

AbstractHttpServerMetricsHandler	back to summary
protected AbstractHttpServerMetricsHandler(Function<String, String> methodTagValue, Function<String, String> uriTagValue)

AbstractHttpServerMetricsHandler

back to summary

protected AbstractHttpServerMetricsHandler(Function<String, String> methodTagValue, Function<String, String> uriTagValue)

AbstractHttpServerMetricsHandler	back to summary
protected AbstractHttpServerMetricsHandler(AbstractHttpServerMetricsHandler copy)

AbstractHttpServerMetricsHandler

back to summary

protected AbstractHttpServerMetricsHandler(AbstractHttpServerMetricsHandler copy)

Method Detail

channelActive back to summary

channelActive	back to summary
public void channelActive(ChannelHandlerContext ctx) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelActive. Implements io.netty.channel.ChannelInboundHandler.channelActive. Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelActive. Calls `ChannelHandlerContext#fireChannelActive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Annotations @Override

public void channelActive(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelActive.

Implements io.netty.channel.ChannelInboundHandler.channelActive.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelActive.

Calls ChannelHandlerContext#fireChannelActive() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Annotations

@Override

channelInactive back to summary

channelInactive	back to summary
public void channelInactive(ChannelHandlerContext ctx) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Implements io.netty.channel.ChannelInboundHandler.channelInactive. Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelInactive. Calls `ChannelHandlerContext#fireChannelInactive()` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Annotations @Override

public void channelInactive(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelInactive.

Implements io.netty.channel.ChannelInboundHandler.channelInactive.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelInactive.

Calls ChannelHandlerContext#fireChannelInactive() to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Annotations

@Override

channelRead back to summary

channelRead	back to summary
public void channelRead(ChannelHandlerContext ctx, Object msg) Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Implements io.netty.channel.ChannelInboundHandler.channelRead. Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead. Calls `ChannelHandlerContext#fireChannelRead(Object)` to forward to the next `ChannelInboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Annotations @Override

public void channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Annotations

@Override

exceptionCaught back to summary

exceptionCaught	back to summary
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught. Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught. Doc from io.netty.channel.ChannelHandler.exceptionCaught. Gets called if a `Throwable` was thrown. Annotations @Override

public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.exceptionCaught.

Implements io.netty.channel.ChannelHandler.exceptionCaught, io.netty.channel.ChannelInboundHandler.exceptionCaught.

Doc from io.netty.channel.ChannelHandler.exceptionCaught.

Gets called if a Throwable was thrown.

Annotations

@Override

extractProcessedDataFromBuffer	back to summary
private long extractProcessedDataFromBuffer(Object msg)

recordActiveConnection	back to summary
protected void recordActiveConnection(SocketAddress localAddress)

recordClosedStream	back to summary
protected void recordClosedStream(SocketAddress localAddress)

recorder	back to summary
protected abstract HttpServerMetricsRecorder recorder()

recordException	back to summary
protected void recordException(HttpServerOperations ops, String path)

recordInactiveConnection	back to summary
protected void recordInactiveConnection(SocketAddress localAddress)

recordInactiveConnectionOrStream	back to summary
pack-priv void recordInactiveConnectionOrStream(Channel channel)

recordOpenStream	back to summary
protected void recordOpenStream(SocketAddress localAddress)

recordRead	back to summary
protected void recordRead(HttpServerOperations ops, String path, String method)

recordWrite	back to summary
protected void recordWrite(HttpServerOperations ops, String path, String method, String status)

startRead	back to summary
protected void startRead(HttpServerOperations ops, String path, String method)

startWrite	back to summary
protected void startWrite(HttpServerOperations ops, String path, String method, String status)

write back to summary

write	back to summary
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) Overrides io.netty.channel.ChannelDuplexHandler.write. Implements io.netty.channel.ChannelOutboundHandler.write. Doc from io.netty.channel.ChannelDuplexHandler.write. Calls `ChannelHandlerContext#write(Object, ChannelPromise)` to forward to the next `ChannelOutboundHandler` in the `ChannelPipeline`. Sub-classes may override this method to change behavior. Parameters ctx:ChannelHandlerContext Doc from io.netty.channel.ChannelOutboundHandler.write. the `ChannelHandlerContext` for which the write operation is made msg:Object Doc from io.netty.channel.ChannelOutboundHandler.write. the message to write promise:ChannelPromise Doc from io.netty.channel.ChannelOutboundHandler.write. the `ChannelPromise` to notify once the operation completes Annotations @Override @SuppressWarnings:FutureReturnValueIgnored