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.

Constructor Summary

Constructors

Constructor	Description
VeniceControllerRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Summary

Modifier and Type	Method	Description
DiscoverClusterGrpcResponse	discoverCluster(DiscoverClusterGrpcRequest request)
Admin	getAdmin()
ClusterAdminOpsRequestHandler	getClusterAdminOpsRequestHandler()
VeniceControllerAccessManager	getControllerAccessManager()
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.
StoreRequestHandler	getStoreRequestHandler()

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceControllerRequestHandler

public VeniceControllerRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Details

getAdmin

public Admin getAdmin()

getStoreRequestHandler

public StoreRequestHandler getStoreRequestHandler()

getClusterAdminOpsRequestHandler

public ClusterAdminOpsRequestHandler getClusterAdminOpsRequestHandler()

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)

getControllerAccessManager

public VeniceControllerAccessManager getControllerAccessManager()