HTTP functionality for the Reactor Netty library 1.1.16 · reactor.netty.http.client.AbstractHttpClientMetricsHandler

Field Summary

Modifier and Type	Field and Description
pack-priv ContextView	contextView
pack-priv long	dataReceived
pack-priv long	dataReceivedTime
pack-priv long	dataSent
pack-priv long	dataSentTime
pack-priv int	lastReadSeq
pack-priv int	lastWriteSeq
private static final Logger	log
pack-priv String	method
pack-priv String	path
pack-priv String	status
pack-priv final Function<String, String>	uriTagValue

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
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 void	extractDetailsFromHttpRequest(ChannelHandlerContext ctx, HttpRequest request)
private long	extractProcessedDataFromBuffer(Object msg)
protected abstract HttpClientMetricsRecorder	recorder()
protected void	recordException(ChannelHandlerContext ctx)
protected void	recordRead(Channel channel)
protected void	recordWrite(SocketAddress address)
protected void	reset()
private String	resolveUri(ChannelHandlerContext ctx)
protected void	startRead(HttpResponse msg)
protected void	startWrite(HttpRequest msg, Channel channel)
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`.

Inherited from io.netty.channel.ChannelDuplexHandler:: bind close connect deregister disconnect flush read

Field Detail

contextView	back to summary
pack-priv ContextView contextView

dataReceived	back to summary
pack-priv long dataReceived

dataReceivedTime	back to summary
pack-priv long dataReceivedTime

dataSent	back to summary
pack-priv long dataSent

dataSentTime	back to summary
pack-priv long dataSentTime

lastReadSeq	back to summary
pack-priv int lastReadSeq

lastWriteSeq	back to summary
pack-priv int lastWriteSeq

log	back to summary
private static final Logger log

method	back to summary
pack-priv String method

path	back to summary
pack-priv String path

status	back to summary
pack-priv String status

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

Constructor Detail

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

AbstractHttpClientMetricsHandler	back to summary
protected AbstractHttpClientMetricsHandler(AbstractHttpClientMetricsHandler copy)

Method Detail

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

extractDetailsFromHttpRequest	back to summary
private void extractDetailsFromHttpRequest(ChannelHandlerContext ctx, HttpRequest request)

extractProcessedDataFromBuffer	back to summary
private long extractProcessedDataFromBuffer(Object msg)

recorder	back to summary
protected abstract HttpClientMetricsRecorder recorder()

recordException	back to summary
protected void recordException(ChannelHandlerContext ctx)

recordRead	back to summary
protected void recordRead(Channel channel)

recordWrite	back to summary
protected void recordWrite(SocketAddress address)

reset	back to summary
protected void reset()

resolveUri	back to summary
private String resolveUri(ChannelHandlerContext ctx)

startRead	back to summary
protected void startRead(HttpResponse msg)

startWrite	back to summary
protected void startWrite(HttpRequest msg, Channel channel)

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