Package com.linkedin.venice.controller.server

Class StoreRequestHandler

java.lang.Object

com.linkedin.venice.controller.server.StoreRequestHandler

public class StoreRequestHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_STORE_OWNER

Constructor Summary

Constructors

Constructor	Description
StoreRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Summary

Modifier and Type	Method	Description
void	checkResourceCleanupForStoreCreation(ClusterStoreGrpcInfo request)
CreateStoreGrpcResponse	createStore(CreateStoreGrpcRequest request)	Creates a new store in the specified Venice cluster with the provided parameters.
DeleteAclForStoreGrpcResponse	deleteAclForStore(DeleteAclForStoreGrpcRequest request)
GetAclForStoreGrpcResponse	getAclForStore(GetAclForStoreGrpcRequest request)
RepushInfo	getRepushInfo(String clusterName, String storeName, Optional<String> fabric)	Retrieves repush information for a store.
StoreInfo	getStore(String clusterName, String storeName)	Gets store information for a given store in a cluster.
ListStoresGrpcResponse	listStores(ListStoresGrpcRequest request)	Lists all stores in the specified cluster with optional filtering.
UpdateAclForStoreGrpcResponse	updateAclForStore(UpdateAclForStoreGrpcRequest request)
ValidateStoreDeletedGrpcResponse	validateStoreDeleted(ValidateStoreDeletedGrpcRequest request)	Validates whether a store has been successfully deleted.

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

StoreRequestHandler

public StoreRequestHandler(ControllerRequestHandlerDependencies dependencies)

Method Details

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

updateAclForStore

public UpdateAclForStoreGrpcResponse updateAclForStore(UpdateAclForStoreGrpcRequest request)

getAclForStore

public GetAclForStoreGrpcResponse getAclForStore(GetAclForStoreGrpcRequest request)

deleteAclForStore

public DeleteAclForStoreGrpcResponse deleteAclForStore(DeleteAclForStoreGrpcRequest request)

checkResourceCleanupForStoreCreation

public void checkResourceCleanupForStoreCreation(ClusterStoreGrpcInfo request)

validateStoreDeleted

public ValidateStoreDeletedGrpcResponse validateStoreDeleted(ValidateStoreDeletedGrpcRequest request)

Validates whether a store has been successfully deleted.

Parameters:

request - the request containing cluster and store name

Returns:

response indicating if store is deleted and reason if not

listStores

public ListStoresGrpcResponse listStores(ListStoresGrpcRequest request)

Lists all stores in the specified cluster with optional filtering.

Parameters:

request - the request containing cluster name and optional filters

Returns:

response containing the list of store names

getRepushInfo

public RepushInfo getRepushInfo(String clusterName,
 String storeName,
 Optional<String> fabric)

Retrieves repush information for a store. No ACL check required - reading repush info is public.

Parameters:

clusterName - the cluster name

storeName - the store name

fabric - optional fabric for multi-region setups

Returns:

RepushInfo containing repush information including version and Kafka details

getStore

public StoreInfo getStore(String clusterName,
 String storeName)

Gets store information for a given store in a cluster.

Parameters:

clusterName - the name of the cluster

storeName - the name of the store

Returns:

StoreInfo containing the store metadata