com.spotify.apollo.request

Interface OngoingRequest

All Known Subinterfaces:

TrackedOngoingRequest

All Known Implementing Classes:

FakeOngoingRequest, ForwardingOngoingRequest

public interface OngoingRequest

A request that is being processed.

Field Summary

Fields

Modifier and Type	Field and Description
static InetSocketAddress	PORT_ZERO
static ServerInfo	UNKNOWN_SERVER_INFO

Method Summary

Modifier and Type	Method and Description
default long	arrivalTimeNanos() Get the arrival time of the incoming request in nanoseconds.
void	drop() Drop the request.
boolean	isExpired()
void	reply(Response<okio.ByteString> response) Reply to the request with a Response.
Request	request() Returns the Request.
default ServerInfo	serverInfo() Returns an identifier for the server where this request originated.

Field Detail

PORT_ZERO

static final InetSocketAddress PORT_ZERO

UNKNOWN_SERVER_INFO

static final ServerInfo UNKNOWN_SERVER_INFO

Method Detail

request

Request request()

Returns the Request.

serverInfo

default ServerInfo serverInfo()

Returns an identifier for the server where this request originated.

reply

void reply(Response<okio.ByteString> response)

Reply to the request with a Response.

Parameters:

response - Response to send as reply

drop

void drop()

Drop the request.

isExpired

boolean isExpired()

arrivalTimeNanos

default long arrivalTimeNanos()

Get the arrival time of the incoming request in nanoseconds. Note that this is not unix epoch as the time is provided by System.nanoTime(). To get unix epoch time, do something like:

 
 long processingTimeNanos = System.nanoTime() - requestContext.arrivalTimeNanos();
 long arrivalTimeUnixEpochMillis = System.currentTimeMillis() +
                                   TimeUnit.NANOSECONDS.toMillis(processingTimeNanos);
 
 

See Also:

System.nanoTime()