Package com.linkedin.venice.router.api
package com.linkedin.venice.router.api
-
ClassDescriptionA POJO to store the response content and additional compression related metadata.DictionaryRetrievalService runs in a producer-consumer pattern.This class serves as the shadow read handler of the meta system store.Right now, there is no simple way to capture all the exception cases with DDS Router.
RouterHeartbeat
is a service that monitors and reports the health of current live instances in the Venice cluster.RouterKey
encapsulates the required information for a key in a router request.This class contains all theScatterGatherMode
being used in Venice Router.A specializedDefaultFullHttpResponse
object to record the decompression time of the records in the response.{code VeniceHostFinder} finds a set of hosts that can serve the given Venice resource partition.VeniceHostHealth
the aggregate statistics for HostHealthStats.This is used to initialize aMetrics
for each request.This enum is used to define various routing strategies for multi-key requests.VenicePartitionFinder
provides methods to find the partition name or number for the given data.VenicePathParser<HTTP_REQUEST extends BasicHttpRequest>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'.Created by mwise on 4/25/16.VeniceResponseAggregator
aggregates the sub-responses returned by storage node for a multi-get request.This class is used to handle all the decompression related logic in Router, and it will be used inVeniceResponseAggregator
for regular requests andVeniceDispatcher
for streaming requests.VeniceVersionFinder
provides methods to find the version for a given store.