Package com.linkedin.venice.listener
package com.linkedin.venice.listener
-
ClassDescriptionExpects a GetRequestObject which has store name, key, and partition Queries the local store for the associated value writes the value (as a byte[]) back down the stackThis class provides the unified way to manager venice listener.Service that listens on configured port to accept incoming GET requestswraps raw bytes into an HTTP response object that HttpServerCodec expectsMonitors the stream, when it gets enough bytes that form a genuine object, it deserializes the object and passes it along the stack.Together with
ServerStoreAclHandler, Server will allow two kinds of access pattern: 1.A wrapper that holds reference for various repositories responsible for constructing metadata responses upon request.We need to be able to record server side statistics for gRPC requests.Together withServerAclHandler, Server will allow two kinds of access pattern: 1.StorageReadRequestHandlerwill take the incoming read requests from routerRouterRequest, and delegate the lookup request to a thread poolStorageReadRequestHandler.executor, which is being shared by all the requests.This class implements the fast value schema/latest value schema lookup with acceptable delay.This utility is used to manage all the HTTP/2 related configs and offer a way to spin up a pipeline to support both HTTP/1.1 and HTTP/2.Currently this VerifySslHandler is only used in servers or the isolated ingestion process.