Package com.linkedin.venice.router.api

Class VenicePathParser

java.lang.Object

com.linkedin.venice.router.api.VenicePathParser

All Implemented Interfaces:

ExtendedResourcePathParser<VenicePath,RouterKey,BasicFullHttpRequest>, ResourcePathParser<VenicePath,RouterKey>

public class VenicePathParser
extends Object
implements ExtendedResourcePathParser<VenicePath,RouterKey,BasicFullHttpRequest>

Inbound single get request to the router will look like: GET /storage/storeName/key?f=fmt 'storage' is a literal, meaning we will request the value for a single key storeName will be the name of the requested store key is the key being looked up fmt is an optional format parameter, one of 'string' or 'b64'. If omitted, assumed to be 'string' Batch get requests look like: POST /storage/storeName And the keys are concatenated in the POST body. The VenicePathParser is responsible for looking up the active version of the store, and constructing the store-version

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACTION_DISABLE
static final String	ACTION_ENABLE
static final String	SEP
static final int	STORE_MAX_LENGTH
static final Pattern	STORE_PATTERN
static final String	TASK_READ_QUOTA_THROTTLE
static final String	TYPE_ADMIN
static final String	TYPE_BLOB_DISCOVERY
static final String	TYPE_CLUSTER_DISCOVERY
static final String	TYPE_COMPUTE
static final String	TYPE_CURRENT_VERSION
static final String	TYPE_GET_UPDATE_SCHEMA
static final String	TYPE_HEALTH_CHECK
static final String	TYPE_KEY_SCHEMA
static final String	TYPE_LEADER_CONTROLLER
static final String	TYPE_LEADER_CONTROLLER_LEGACY	Deprecated.
static final String	TYPE_REQUEST_TOPIC
static final String	TYPE_RESOURCE_STATE
static final String	TYPE_STORAGE
static final String	TYPE_VALUE_SCHEMA

Constructor Summary

Constructors

Constructor	Description
VenicePathParser(VeniceVersionFinder versionFinder, VenicePartitionFinder partitionFinder, RouterStats<AggRouterHttpRequestStats> routerStats, ReadOnlyStoreRepository storeRepository, VeniceRouterConfig routerConfig, CompressorFactory compressorFactory, io.tehuti.metrics.MetricsRepository metricsRepository, ScheduledExecutorService retryManagerScheduler, NameRepository nameRepository)

Method Summary

Modifier and Type	Method	Description
static boolean	isStoreNameValid(String storeName)
VenicePath	parseResourceUri(String uri)
VenicePath	parseResourceUri(String uri, BasicFullHttpRequest fullHttpRequest)
VenicePath	substitutePartitionKey(VenicePath path, RouterKey s)
VenicePath	substitutePartitionKey(VenicePath path, Collection<RouterKey> s)

Methods inherited from class java.lang.Object

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

Field Details

STORE_PATTERN

public static final Pattern STORE_PATTERN

STORE_MAX_LENGTH

public static final int STORE_MAX_LENGTH

See Also:

• Constant Field Values

SEP

public static final String SEP

See Also:

• Constant Field Values

TYPE_STORAGE

public static final String TYPE_STORAGE

See Also:

• Constant Field Values

TYPE_COMPUTE

public static final String TYPE_COMPUTE

See Also:

• Constant Field Values

TASK_READ_QUOTA_THROTTLE

public static final String TASK_READ_QUOTA_THROTTLE

See Also:

• Constant Field Values

ACTION_ENABLE

public static final String ACTION_ENABLE

See Also:

• Constant Field Values

ACTION_DISABLE

public static final String ACTION_DISABLE

See Also:

• Constant Field Values

TYPE_LEADER_CONTROLLER

public static final String TYPE_LEADER_CONTROLLER

TYPE_LEADER_CONTROLLER_LEGACY

@Deprecated
public static final String TYPE_LEADER_CONTROLLER_LEGACY

Deprecated.

TYPE_KEY_SCHEMA

public static final String TYPE_KEY_SCHEMA

TYPE_VALUE_SCHEMA

public static final String TYPE_VALUE_SCHEMA

TYPE_GET_UPDATE_SCHEMA

public static final String TYPE_GET_UPDATE_SCHEMA

TYPE_CLUSTER_DISCOVERY

public static final String TYPE_CLUSTER_DISCOVERY

TYPE_REQUEST_TOPIC

public static final String TYPE_REQUEST_TOPIC

TYPE_HEALTH_CHECK

public static final String TYPE_HEALTH_CHECK

TYPE_ADMIN

public static final String TYPE_ADMIN

TYPE_RESOURCE_STATE

public static final String TYPE_RESOURCE_STATE

TYPE_CURRENT_VERSION

public static final String TYPE_CURRENT_VERSION

TYPE_BLOB_DISCOVERY

public static final String TYPE_BLOB_DISCOVERY

Constructor Details

VenicePathParser

public VenicePathParser(VeniceVersionFinder versionFinder,
 VenicePartitionFinder partitionFinder,
 RouterStats<AggRouterHttpRequestStats> routerStats,
 ReadOnlyStoreRepository storeRepository,
 VeniceRouterConfig routerConfig,
 CompressorFactory compressorFactory,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 ScheduledExecutorService retryManagerScheduler,
 NameRepository nameRepository)

Method Details

parseResourceUri

public VenicePath parseResourceUri(String uri,
 BasicFullHttpRequest fullHttpRequest)
                            throws RouterException

Specified by:

parseResourceUri in interface ExtendedResourcePathParser<VenicePath,RouterKey,BasicFullHttpRequest>

Throws:

RouterException

parseResourceUri

public VenicePath parseResourceUri(String uri)
                            throws RouterException

Specified by:

parseResourceUri in interface ResourcePathParser<VenicePath,RouterKey>

Throws:

RouterException

substitutePartitionKey

public VenicePath substitutePartitionKey(VenicePath path,
 RouterKey s)

Specified by:

substitutePartitionKey in interface ResourcePathParser<VenicePath,RouterKey>

substitutePartitionKey

public VenicePath substitutePartitionKey(VenicePath path,
 Collection<RouterKey> s)

Specified by:

substitutePartitionKey in interface ResourcePathParser<VenicePath,RouterKey>

isStoreNameValid

public static boolean isStoreNameValid(String storeName)