| ErrorCatchingHandler |
Expects 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 stack
|
| HttpChannelInitializer |
|
| ListenerManager<T> |
This class provides the unified way to manager venice listener.
|
| ListenerService |
Service that listens on configured port to accept incoming GET requests
|
| OutboundHttpWrapperHandler |
wraps raw bytes into an HTTP response object that HttpServerCodec expects
|
| ReadQuotaEnforcementHandler |
|
| RouterRequestHttpHandler |
Monitors the stream, when it gets enough bytes that form a genuine object,
it deserializes the object and passes it along the stack.
|
| ServerAclHandler |
|
| ServerConnectionStatsHandler |
|
| ServerHandlerUtils |
|
| ServerReadMetadataRepository |
A wrapper that holds reference for various repositories responsible for constructing metadata responses upon request.
|
| ServerStatsContext |
We need to be able to record server side statistics for gRPC requests.
|
| ServerStoreAclHandler |
Together with ServerAclHandler, Server will allow two kinds of access pattern:
1. |
| StatsHandler |
|
| StorageReadRequestHandler |
StorageReadRequestHandler will take the incoming read requests from router RouterRequest, and delegate
the lookup request to a thread pool StorageReadRequestHandler.executor, which is being shared by all the requests. |
| StoreValueSchemasCacheService |
This class implements the fast value schema/latest value schema lookup with acceptable delay.
|
| VeniceHttp2PipelineInitializerBuilder |
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.
|
| VerifySslHandler |
Currently this VerifySslHandler is only used in servers or the isolated ingestion process.
|