Package com.linkedin.venice.listener.request

Class RouterRequest

java.lang.Object

com.linkedin.venice.listener.request.RouterRequest

Direct Known Subclasses:

GetRouterRequest, MultiKeyRouterRequestWrapper

public abstract class RouterRequest
extends java.lang.Object

RouterRequest is an abstract base class for single-get and multi-get operations.

See Also:

GetRouterRequest, MultiGetRouterRequestWrapper

Field Summary

Fields

Modifier and Type	Field	Description
static long	NO_REQUEST_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
RouterRequest(java.lang.String resourceName, boolean isRetryRequest, boolean isStreamingRequest)
RouterRequest(java.lang.String resourceName, io.netty.handler.codec.http.HttpRequest request)

Method Summary

Modifier and Type	Method	Description
abstract int	getKeyCount()
abstract RequestType	getRequestType()
java.lang.String	getResourceName()
java.lang.String	getStoreName()
boolean	isRetryRequest()
boolean	isStreamingRequest()
void	setRequestTimeoutInNS(long requestTimeoutInNS)
boolean	shouldRequestBeTerminatedEarly()

Methods inherited from class java.lang.Object

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

Field Detail

NO_REQUEST_TIMEOUT

public static final long NO_REQUEST_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

RouterRequest

public RouterRequest(java.lang.String resourceName,
                     io.netty.handler.codec.http.HttpRequest request)

RouterRequest

public RouterRequest(java.lang.String resourceName,
                     boolean isRetryRequest,
                     boolean isStreamingRequest)

Method Detail

setRequestTimeoutInNS

public void setRequestTimeoutInNS(long requestTimeoutInNS)

getResourceName

public java.lang.String getResourceName()

getStoreName

public java.lang.String getStoreName()

getRequestType

public abstract RequestType getRequestType()

getKeyCount

public abstract int getKeyCount()

isRetryRequest

public boolean isRetryRequest()

isStreamingRequest

public boolean isStreamingRequest()

shouldRequestBeTerminatedEarly

public boolean shouldRequestBeTerminatedEarly()