Package com.linkedin.venice.controller.server

Class StoreRequestHandler

java.lang.Object
com.linkedin.venice.controller.server.StoreRequestHandler
public class StoreRequestHandler extends Object

  • Field Details

  • Constructor Details

  • 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

    • getStoreStatuses

      public Map<String,String> getStoreStatuses(String clusterName)
      Gets the health status of all stores in the specified cluster.
      Parameters:
      clusterName - the name of the cluster
      Returns:
      map of store names to their statuses

    • 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