Package com.linkedin.venice.listener.request

Class GetRouterRequest

java.lang.Object

com.linkedin.venice.listener.request.RouterRequest

com.linkedin.venice.listener.request.GetRouterRequest

public class GetRouterRequest
extends RouterRequest

GetRouterRequest encapsulates a GET request to storage/resourcename/partition/key on the storage node for a single-get operation.

Field Summary

Fields inherited from class com.linkedin.venice.listener.request.RouterRequest

NO_REQUEST_TIMEOUT

Method Summary

Modifier and Type	Method	Description
byte[]	getKeyBytes()
static byte[]	getKeyBytesFromUrlKeyString(String keyString)
int	getKeyCount()
int	getPartition()
RequestType	getRequestType()
static GetRouterRequest	grpcGetRouterRequest(VeniceClientRequest request)
static GetRouterRequest	parseGetHttpRequest(io.netty.handler.codec.http.HttpRequest request, String[] requestParts)
static void	verifyApiVersion(io.netty.handler.codec.http.HttpHeaders headers, String expectedVersion)	throws VeniceException if we don't handle the specified api version

Methods inherited from class com.linkedin.venice.listener.request.RouterRequest

getResourceName, getStoreName, isRetryRequest, isStreamingRequest, setRequestTimeoutInNS, shouldRequestBeTerminatedEarly

Methods inherited from class java.lang.Object

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

Method Details

getPartition

public int getPartition()

getKeyBytes

public byte[] getKeyBytes()

getRequestType

public RequestType getRequestType()

Specified by:

getRequestType in class RouterRequest

getKeyCount

public int getKeyCount()

Specified by:

getKeyCount in class RouterRequest

parseGetHttpRequest

public static GetRouterRequest parseGetHttpRequest(io.netty.handler.codec.http.HttpRequest request,
 String[] requestParts)

grpcGetRouterRequest

public static GetRouterRequest grpcGetRouterRequest(VeniceClientRequest request)

getKeyBytesFromUrlKeyString

public static byte[] getKeyBytesFromUrlKeyString(String keyString)

verifyApiVersion

public static void verifyApiVersion(io.netty.handler.codec.http.HttpHeaders headers,
 String expectedVersion)

throws VeniceException if we don't handle the specified api version

Parameters:

headers -