Package org.mockserver.mock.action.http

Class HttpActionHandler

java.lang.Object

org.mockserver.mock.action.http.HttpActionHandler

public class HttpActionHandler
extends Object

Author:

jamesdbloom

Field Summary

Fields

Modifier and Type	Field	Description
static final io.netty.util.AttributeKey<InetSocketAddress>	REMOTE_SOCKET
static final String	RESPONSE_TIME_HEADER	Internal header carrying the upstream round-trip time (in milliseconds) on the LOGGED FORWARDED_REQUEST response only.

Constructor Summary

Constructors

Constructor	Description
HttpActionHandler(Configuration configuration, io.netty.channel.EventLoopGroup eventLoopGroup, HttpState httpStateHandler, List<ProxyConfiguration> proxyConfigurations, NettySslContextFactory nettySslContextFactory)

Method Summary

Modifier and Type	Method	Description
NettyHttpClient	getHttpClient()
static InetSocketAddress	getRemoteAddress(io.netty.channel.ChannelHandlerContext ctx)
void	processAction(HttpRequest request, ResponseWriter responseWriter, io.netty.channel.ChannelHandlerContext ctx, Set<String> localAddresses, boolean proxyingRequest, boolean synchronous)
void	processEarlyAction(HttpRequest request, Expectation expectation, io.netty.channel.ChannelHandlerContext ctx, ResponseWriter earlyResponseWriter, boolean synchronous)	Dispatch an early-matched expectation before the request body has been received.
static void	recordLlmUsageMetrics(Provider provider, String model, Completion completion)	Increment LLM token/cost Prometheus counters and record cost against the cost-budget circuit-breaker.
static void	setRemoteAddress(io.netty.channel.ChannelHandlerContext ctx, InetSocketAddress inetSocketAddress)

Methods inherited from class java.lang.Object

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

Field Details

REMOTE_SOCKET

public static final io.netty.util.AttributeKey<InetSocketAddress> REMOTE_SOCKET

RESPONSE_TIME_HEADER

public static final String RESPONSE_TIME_HEADER

Internal header carrying the upstream round-trip time (in milliseconds) on the LOGGED FORWARDED_REQUEST response only. Mirrors the x-mockserver-streamed / x-mockserver-chunk-delays-ms convention: it is attached to a clone stored in the event log and is NEVER written to the real client. The LLM optimisation report reads it to populate per-call upstream latency.

See Also:

• Constant Field Values

Constructor Details

HttpActionHandler

public HttpActionHandler(Configuration configuration,
 io.netty.channel.EventLoopGroup eventLoopGroup,
 HttpState httpStateHandler,
 List<ProxyConfiguration> proxyConfigurations,
 NettySslContextFactory nettySslContextFactory)

Method Details

processEarlyAction

public void processEarlyAction(HttpRequest request,
 Expectation expectation,
 io.netty.channel.ChannelHandlerContext ctx,
 ResponseWriter earlyResponseWriter,
 boolean synchronous)

Dispatch an early-matched expectation before the request body has been received. Supports Action.Type.RESPONSE and Action.Type.ERROR only; other action types are rejected by RequestMatchers.validateRespondBeforeBody at expectation-add time.

processAction

public void processAction(HttpRequest request,
 ResponseWriter responseWriter,
 io.netty.channel.ChannelHandlerContext ctx,
 Set<String> localAddresses,
 boolean proxyingRequest,
 boolean synchronous)

getHttpClient

public NettyHttpClient getHttpClient()

getRemoteAddress

public static InetSocketAddress getRemoteAddress(io.netty.channel.ChannelHandlerContext ctx)

setRemoteAddress

public static void setRemoteAddress(io.netty.channel.ChannelHandlerContext ctx,
 InetSocketAddress inetSocketAddress)

recordLlmUsageMetrics

public static void recordLlmUsageMetrics(Provider provider,
 String model,
 Completion completion)

Increment LLM token/cost Prometheus counters and record cost against the cost-budget circuit-breaker. Shared by both the forward path and the mock path (via HttpLlmResponseActionHandler). Fail-soft.