Package com.linkedin.venice.controller.server

Class VeniceControllerRequestHandler

java.lang.Object

com.linkedin.venice.controller.server.VeniceControllerRequestHandler

public class VeniceControllerRequestHandler
extends Object

The core handler for processing incoming requests in the VeniceController. Acts as the central entry point for handling requests received via both HTTP/REST and gRPC protocols. This class is responsible for managing all request handling operations for the VeniceController.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_STORE_OWNER

Constructor Summary

Constructors

Constructor	Description
VeniceControllerRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Summary

Modifier and Type	Method	Description
CreateStoreGrpcResponse	createStore(CreateStoreGrpcRequest request)	Creates a new store in the specified Venice cluster with the provided parameters.
DiscoverClusterGrpcResponse	discoverCluster(DiscoverClusterGrpcRequest request)
LeaderControllerGrpcResponse	getLeaderControllerDetails(LeaderControllerGrpcRequest request)	The response is passed as an argument to avoid creating duplicate response objects for HTTP requests and to simplify unit testing with gRPC.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_STORE_OWNER

public static final String DEFAULT_STORE_OWNER

See Also:

• Constant Field Values

Constructor Details

VeniceControllerRequestHandler

public VeniceControllerRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Details

getLeaderControllerDetails

public LeaderControllerGrpcResponse getLeaderControllerDetails(LeaderControllerGrpcRequest request)

The response is passed as an argument to avoid creating duplicate response objects for HTTP requests and to simplify unit testing with gRPC. Once the transition to gRPC is complete, we can eliminate the need to pass the response as an argument and instead construct and return it directly within the method.

discoverCluster

public DiscoverClusterGrpcResponse discoverCluster(DiscoverClusterGrpcRequest request)

createStore

public CreateStoreGrpcResponse createStore(CreateStoreGrpcRequest request)

Creates a new store in the specified Venice cluster with the provided parameters.

Parameters:

request - the request object containing all necessary details for the creation of the store